From 0912e30fb375f60bade22fd8cf7331e1b8d77659 Mon Sep 17 00:00:00 2001 From: Sam Anthony Date: Fri, 22 Nov 2024 12:39:53 -0500 Subject: ReliableUnicastReceiver --- src/main/java/derms/util/ThreadPool.java | 22 ++++++++++++++++++++++ 1 file changed, 22 insertions(+) create mode 100644 src/main/java/derms/util/ThreadPool.java (limited to 'src/main/java/derms/util/ThreadPool.java') diff --git a/src/main/java/derms/util/ThreadPool.java b/src/main/java/derms/util/ThreadPool.java new file mode 100644 index 0000000..33588ff --- /dev/null +++ b/src/main/java/derms/util/ThreadPool.java @@ -0,0 +1,22 @@ +package derms.util; + +import java.time.Duration; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.TimeUnit; +import java.util.logging.Logger; + +public class ThreadPool { + public static final Duration timeout = Duration.ofSeconds(1); + + public static void shutDown(ExecutorService pool, Logger log) { + pool.shutdownNow(); + try { + if (!pool.awaitTermination(timeout.toMillis(), TimeUnit.MILLISECONDS)) + log.warning("Thread pool did not terminate after " + timeout); + } catch (InterruptedException e) { + log.warning("Interrupted while terminating thread pool: " + e.getMessage()); + // Preserve interrupt status. + Thread.currentThread().interrupt(); + } + } +} -- cgit v1.2.3