import java.util.Locale;
import java.util.Map;
import java.util.Optional;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;
public class Util {
}
return map;
}
-
- public static void closeExecutorService(ExecutorService executor) {
- executor.shutdown();
- try {
- if (!executor.awaitTermination(5, TimeUnit.MINUTES)) {
- executor.shutdownNow();
- if (!executor.awaitTermination(1, TimeUnit.MINUTES)) {
- logger.warn("Failed to shutdown executor service");
- }
- }
- } catch (InterruptedException e) {
- executor.shutdownNow();
- Thread.currentThread().interrupt();
- }
- }
}