do not use the thread pool if it's shutdown

should fix koush#256
robUx4 · Oct 6, 2014 · 864076e · 864076e
1 parent 5530bb8
commit 864076e
Showing 1 changed file with 35 additions and 32 deletions.
diff --git a/AndroidAsync/src/com/koushikdutta/async/AsyncServer.java b/AndroidAsync/src/com/koushikdutta/async/AsyncServer.java
@@ -122,17 +122,18 @@ public void removeAllCallbacks(Object scheduled) {
     }
 
     private static void wakeup(final SelectorWrapper selector) {
-        synchronousWorkers.execute(new Runnable() {
-            @Override
-            public void run() {
-                try {
-                    selector.wakeupOnce();
-                }
-                catch (Exception e) {
-                    Log.i(LOGTAG, "Selector Exception? L Preview?");
+        if (!synchronousWorkers.isShutdown()) {
+            synchronousWorkers.execute(new Runnable() {
+                @Override
+                public void run() {
+                    try {
+                        selector.wakeupOnce();
+                    } catch (Exception e) {
+                        Log.i(LOGTAG, "Selector Exception? L Preview?");
+                    }
                 }
-            }
-        });
+            });
+        }
     }
 
     public Object postDelayed(Runnable runnable, long delay) {
@@ -399,29 +400,31 @@ public Cancellable connectSocket(final String host, final int port, final Connec
     private static ExecutorService synchronousWorkers = Executors.newFixedThreadPool(4);
     public Future<InetAddress[]> getAllByName(final String host) {
         final SimpleFuture<InetAddress[]> ret = new SimpleFuture<InetAddress[]>();
-        synchronousWorkers.execute(new Runnable() {
-            @Override
-            public void run() {
-                try {
-                    final InetAddress[] result = InetAddress.getAllByName(host);
-                    if (result == null || result.length == 0)
-                        throw new HostnameResolutionException("no addresses for host");
-                    post(new Runnable() {
-                        @Override
-                        public void run() {
-                            ret.setComplete(null, result);
-                        }
-                    });
-                } catch (final Exception e) {
-                    post(new Runnable() {
-                        @Override
-                        public void run() {
-                            ret.setComplete(e, null);
-                        }
-                    });
+        if (!synchronousWorkers.isShutdown()) {
+            synchronousWorkers.execute(new Runnable() {
+                @Override
+                public void run() {
+                    try {
+                        final InetAddress[] result = InetAddress.getAllByName(host);
+                        if (result == null || result.length == 0)
+                            throw new HostnameResolutionException("no addresses for host");
+                        post(new Runnable() {
+                            @Override
+                            public void run() {
+                                ret.setComplete(null, result);
+                            }
+                        });
+                    } catch (final Exception e) {
+                        post(new Runnable() {
+                            @Override
+                            public void run() {
+                                ret.setComplete(e, null);
+                            }
+                        });
+                    }
                 }
-            }
-        });
+            });
+        }
         return ret;
     }