aboutsummaryrefslogtreecommitdiff
path: root/juick-core/src/main/java/com/juick/util
diff options
context:
space:
mode:
authorGravatar Alexander Alexeev2016-11-13 21:21:45 +0700
committerGravatar Alexander Alexeev2016-11-13 21:21:45 +0700
commit6ba7eb5fe1384ec87cdd0031d185a9b26512a016 (patch)
tree1448ba6c8dda4302e3ad847cb085d49b8b054867 /juick-core/src/main/java/com/juick/util
parentb75258ee5ed84510579050b5dba1edb904a09dfa (diff)
server core module
Diffstat (limited to 'juick-core/src/main/java/com/juick/util')
-rw-r--r--juick-core/src/main/java/com/juick/util/ThreadHelper.java36
1 files changed, 0 insertions, 36 deletions
diff --git a/juick-core/src/main/java/com/juick/util/ThreadHelper.java b/juick-core/src/main/java/com/juick/util/ThreadHelper.java
deleted file mode 100644
index 7304d158..00000000
--- a/juick-core/src/main/java/com/juick/util/ThreadHelper.java
+++ /dev/null
@@ -1,36 +0,0 @@
-package com.juick.util;
-
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.TimeUnit;
-
-/**
- * Created by aalexeev on 11/11/16.
- */
-public class ThreadHelper {
- private ThreadHelper() {
- throw new IllegalStateException();
- }
-
- private static Logger logger = LoggerFactory.getLogger(ThreadHelper.class);
-
- public static void shutdownAndAwaitTermination(ExecutorService pool) {
- pool.shutdown(); // Disable new tasks from being submitted
- try {
- // Wait a while for existing tasks to terminate
- if (!pool.awaitTermination(5, TimeUnit.SECONDS)) {
- pool.shutdownNow(); // Cancel currently executing tasks
- // Wait a while for tasks to respond to being cancelled
- if (!pool.awaitTermination(5, TimeUnit.SECONDS))
- logger.error("Pool did not terminate");
- }
- } catch (InterruptedException ie) {
- // (Re-)Cancel if current thread also interrupted
- pool.shutdownNow();
- // Preserve interrupt status
- Thread.currentThread().interrupt();
- }
- }
-}