Shutdown async executor

This commit is contained in:
Ivan Pekov 2021-10-28 19:19:12 +03:00
parent 8e8b0ca6fc
commit 8a54d4747a
No known key found for this signature in database
GPG Key ID: E44CE4557A5E12E0

View File

@ -45,6 +45,7 @@ import java.util.concurrent.CompletionException;
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ExecutorService; import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import java.util.function.Function; import java.util.function.Function;
import java.util.logging.Level; import java.util.logging.Level;
import java.util.stream.Collector; import java.util.stream.Collector;
@ -166,6 +167,10 @@ public final class CloudExpansionManager {
await.values().forEach(future -> future.cancel(true)); await.values().forEach(future -> future.cancel(true));
await.clear(); await.clear();
ASYNC_EXECUTOR.shutdown();
try {
ASYNC_EXECUTOR.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS);
} catch (InterruptedException ignored) {}
} }
public void fetch(final boolean allowUnverified) { public void fetch(final boolean allowUnverified) {