Added shutdown() for ExecutorService

concurrent/CaptureUncaughtException.java

@@ -3,7 +3,6 @@
 // We make no guarantees that this code is fit for any purpose.
 // Visit http://OnJava8.com for more book information.
 import java.util.concurrent.*;
-import onjava.TimedAbort;
 
 class ExceptionThread2 implements Runnable {
   @Override
@@ -40,21 +39,17 @@ class HandlerThreadFactory implements ThreadFactory {
 
 public class CaptureUncaughtException {
   public static void main(String[] args) {
-    new TimedAbort(4);
     ExecutorService exec = Executors.newCachedThreadPool(
       new HandlerThreadFactory());
     exec.execute(new ExceptionThread2());
+    exec.shutdown();
   }
 }
 /* Output:
-HandlerThreadFactory@14991ad creating new Thread
+HandlerThreadFactory@4e25154f creating new Thread
-created Thread[Thread-1,5,main]
+created Thread[Thread-0,5,main]
-eh = MyUncaughtExceptionHandler@d93b30
+eh = MyUncaughtExceptionHandler@70dea4e
-run() by Thread-1
+run() by Thread-0
-eh = MyUncaughtExceptionHandler@d93b30
+eh = MyUncaughtExceptionHandler@70dea4e
-HandlerThreadFactory@14991ad creating new Thread
-created Thread[Thread-2,5,main]
-eh = MyUncaughtExceptionHandler@1351c58
 caught java.lang.RuntimeException
-TimedAbort 4
 */

concurrent/ExceptionThread.java

@@ -14,5 +14,6 @@ public class ExceptionThread implements Runnable {
   public static void main(String[] args) {
     ExecutorService es = Executors.newCachedThreadPool();
     es.execute(new ExceptionThread());
+    es.shutdown();
   }
 }

concurrent/NaiveExceptionHandling.java

@@ -8,13 +8,15 @@ import java.util.concurrent.*;
 
 public class NaiveExceptionHandling {
   public static void main(String[] args) {
+    ExecutorService es =
+      Executors.newCachedThreadPool();
     try {
-      ExecutorService exec =
+      es.execute(new ExceptionThread());
-        Executors.newCachedThreadPool();
-      exec.execute(new ExceptionThread());
     } catch(RuntimeException ue) {
       // This statement will NOT execute!
       System.out.println("Exception was handled!");
+    } finally {
+      es.shutdown();
     }
   }
 }

concurrent/SettingDefaultHandler.java

@@ -3,18 +3,16 @@
 // We make no guarantees that this code is fit for any purpose.
 // Visit http://OnJava8.com for more book information.
 import java.util.concurrent.*;
-import onjava.TimedAbort;
 
 public class SettingDefaultHandler {
   public static void main(String[] args) {
-    new TimedAbort(4);
     Thread.setDefaultUncaughtExceptionHandler(
       new MyUncaughtExceptionHandler());
     ExecutorService es = Executors.newCachedThreadPool();
     es.execute(new ExceptionThread());
+    es.shutdown();
   }
 }
 /* Output:
 caught java.lang.RuntimeException
-TimedAbort 4
 */

concurrent/SwallowedException.java

@@ -12,6 +12,6 @@ public class SwallowedException {
     exec.submit(() -> {
       throw new RuntimeException();
     });
-    exec.shutdownNow();
+    exec.shutdown();
   }
 }

concurrent/ThreadSize.java

@@ -29,6 +29,8 @@ public class ThreadSize {
       System.out.println(
         e.getClass().getSimpleName() + ": " + count);
       System.exit(0);
+    } finally {
+      exec.shutdown();
     }
   }
 }