Fixes #336 - Though you should also update to Java 8
This commit is contained in:
parent
4cafeb68ca
commit
bbb6346aff
@ -115,13 +115,8 @@ public class SetQueue {
|
|||||||
if (Fawe.get().isJava8()) {
|
if (Fawe.get().isJava8()) {
|
||||||
pool.awaitQuiescence(Long.MAX_VALUE, TimeUnit.MILLISECONDS);
|
pool.awaitQuiescence(Long.MAX_VALUE, TimeUnit.MILLISECONDS);
|
||||||
} else {
|
} else {
|
||||||
try {
|
pool.shutdown();
|
||||||
for (Runnable run : pool.shutdownNow()) {
|
pool.awaitTermination(Long.MAX_VALUE, TimeUnit.MILLISECONDS);
|
||||||
run.run();
|
|
||||||
}
|
|
||||||
} catch (Throwable e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
pool = new ForkJoinPool();
|
pool = new ForkJoinPool();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user