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/net/rmulticast/ReliableMulticast.java | 13 ++----------- 1 file changed, 2 insertions(+), 11 deletions(-) (limited to 'src/main/java/derms/net/rmulticast/ReliableMulticast.java') diff --git a/src/main/java/derms/net/rmulticast/ReliableMulticast.java b/src/main/java/derms/net/rmulticast/ReliableMulticast.java index c201e3a..3894021 100644 --- a/src/main/java/derms/net/rmulticast/ReliableMulticast.java +++ b/src/main/java/derms/net/rmulticast/ReliableMulticast.java @@ -3,6 +3,7 @@ package derms.net.rmulticast; import derms.net.ConcurrentMulticastSocket; import derms.net.MessagePayload; import derms.net.Packet; +import derms.util.ThreadPool; import java.io.IOException; import java.net.*; @@ -18,8 +19,6 @@ import java.util.logging.Logger; * Distributed Systems" in IEEE Transactions on Parallel and Distributed Systems, vol. 1, no. 1, 1990. */ public class ReliableMulticast { - private static final Duration terminationTimeout = Duration.ofSeconds(1); - private final SocketAddress group; private final InetAddress laddr; // Local address. private final Set acks; // Positively acknowledged messages. @@ -64,15 +63,7 @@ public class ReliableMulticast { public void close() { log.info("Shutting down..."); - pool.shutdownNow(); - try { - if (!pool.awaitTermination(terminationTimeout.toMillis(), TimeUnit.MILLISECONDS)) - log.warning("Thread pool did not terminate after " + terminationTimeout); - } catch (InterruptedException e) { - log.warning("Interrupted while terminating thread pool: " + e.getMessage()); - // Preserve interrupt status. - Thread.currentThread().interrupt(); - } + ThreadPool.shutDown(pool, log); outSock.close(); log.info("Finished shutting down."); } -- cgit v1.2.3