未验证 提交 31cba557 编写于 作者: ShardingSphere's avatar ShardingSphere 提交者: GitHub

Merge pull request #637 from ma-xiao-guang-64/dev

优化ExecutorEngine关闭流程
......@@ -216,16 +216,7 @@ public final class ExecutorEngine implements AutoCloseable {
@Override
public void close() {
executorService.shutdown();
try {
if (!executorService.awaitTermination(5, TimeUnit.SECONDS)) {
executorService.shutdownNow();
}
} catch (final InterruptedException ignored) {
}
if (!executorService.isTerminated()) {
newThreadToClose();
}
newThreadToClose();
}
private void newThreadToClose() {
......@@ -234,7 +225,8 @@ public final class ExecutorEngine implements AutoCloseable {
@Override
public void run() {
try {
while (!executorService.awaitTermination(100, TimeUnit.MILLISECONDS)) {
executorService.shutdown();
while (!executorService.awaitTermination(5, TimeUnit.SECONDS)) {
executorService.shutdownNow();
}
} catch (final InterruptedException ex) {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册