fix manager thread block logic

gh-orange · Dec 28, 2018 · d1d30f5 · d1d30f5
1 parent 768373f
commit d1d30f5
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/src/pers/cz/chaoxing/thread/manager/ManagerModel.java b/src/pers/cz/chaoxing/thread/manager/ManagerModel.java
@@ -37,7 +37,7 @@ public abstract class ManagerModel implements PauseCallBack, Runnable, Closeable
 
     @Override
     public final void run() {
-        if (this.threadPoolSize > 0)
+        if (this.threadPoolSize > 0) {
             try {
                 doJob();
             } catch (RequestsException e) {
@@ -48,6 +48,14 @@ public final void run() {
                     threadPool.shutdownNow();
             } catch (Exception ignored) {
             }
+            LongStream.range(0, threadPool.getTaskCount()).mapToObj(i -> {
+                try {
+                    return completionService.take().get();
+                } catch (Exception e) {
+                    return false;
+                }
+            });
+        }
     }
 
     @Override