From 1a5ab9183f2f42dcbcfa11c993d992cbfdb2b382 Mon Sep 17 00:00:00 2001 From: Sam Anthony Date: Mon, 25 Nov 2024 10:49:58 -0500 Subject: optimize CPU usage --- src/main/java/derms/net/rmulticast/Timeout.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) (limited to 'src/main/java/derms/net/rmulticast/Timeout.java') diff --git a/src/main/java/derms/net/rmulticast/Timeout.java b/src/main/java/derms/net/rmulticast/Timeout.java index 5c47e0c..2398b5b 100644 --- a/src/main/java/derms/net/rmulticast/Timeout.java +++ b/src/main/java/derms/net/rmulticast/Timeout.java @@ -1,7 +1,6 @@ package derms.net.rmulticast; import derms.net.MessagePayload; -import derms.util.Wait; import java.time.Duration; import java.util.Set; @@ -31,7 +30,7 @@ class Timeout implements Runnable { public void run() { try { for (;;) { - Wait.forDuration(timeout); + Thread.sleep(timeout.toMillis()); if (acks.contains(msg.id())) { log.info("Message " + msg.id() + "positively ack'ed."); return; -- cgit v1.2.3