Skip to content

Commit e7db39b

Browse files
committed
+ fixed ConseqExecutor#shutdown to block-check workThreadPool actual termination instead of shutdown init
1 parent 74b154c commit e7db39b

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/conseq4j/execute/ConseqExecutor.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -174,7 +174,7 @@ public void shutdown() {
174174
await.until(() -> this.workerThreadPool.getActiveCount() == 0);
175175
await.until(() -> this.latestSequentialTasks.size() == 0);
176176
this.workerThreadPool.shutdown();
177-
await.until(this.workerThreadPool::isShutdown);
177+
await.until(this.workerThreadPool::isTerminated);
178178
this.adminThread.shutdown();
179179
});
180180
shutdownThread.shutdown();

0 commit comments

Comments
 (0)