reliable multicast: prune received list

1 files changed, 15 insertions, 0 deletions

diff --git a/src/main/java/derms/net/rmulticast/Wait.java b/src/main/java/derms/net/rmulticast/Wait.java
new file mode 100644
index 0000000..f1180ed
--- /dev/null
+++ b/src/main/java/derms/net/rmulticast/Wait.java
@@ -0,0 +1,15 @@
+package derms.net.rmulticast;
+
+import java.time.Duration;
+import java.time.Instant;
+
+class Wait {
+    static void forDuration(Duration dur) throws InterruptedException {
+        Instant start = Instant.now();
+        Duration elapsed;
+        do {
+            Thread.yield();
+            elapsed = Duration.between(start, Instant.now());
+        } while (elapsed.compareTo(dur) < 0);
+    }
+}