diff --git a/core/src/main/java/com/boydti/fawe/util/SetQueue.java b/core/src/main/java/com/boydti/fawe/util/SetQueue.java index 6a97c4c7..86984fb8 100644 --- a/core/src/main/java/com/boydti/fawe/util/SetQueue.java +++ b/core/src/main/java/com/boydti/fawe/util/SetQueue.java @@ -115,13 +115,8 @@ public class SetQueue { if (Fawe.get().isJava8()) { pool.awaitQuiescence(Long.MAX_VALUE, TimeUnit.MILLISECONDS); } else { - try { - for (Runnable run : pool.shutdownNow()) { - run.run(); - } - } catch (Throwable e) { - e.printStackTrace(); - } + pool.shutdown(); + pool.awaitTermination(Long.MAX_VALUE, TimeUnit.MILLISECONDS); pool = new ForkJoinPool(); } }