IntSequence and Futures system (no executors)

Author: BuildTools

src/main/java/dev/mv/utilsx/Test.java

@@ -5,7 +5,7 @@
 
 import java.util.Arrays;
 import java.util.List;
-import java.util.Map;
+import java.util.Random;
 
 @SuppressWarnings("unchecked")
 public class Test {
@@ -18,8 +18,8 @@ public static void main(String[] args) {
                 .ints()
                 .take(10)
                 .map(x -> (char) (int) x)
-                .fold("", (s, c) -> s + c)
-                .getUnchecked();
+                .collect();
+
         System.out.println(str);
 
         List<List<Integer>> w = Sequence
@@ -31,9 +31,11 @@ public static void main(String[] args) {
                 .map(Arrays::asList)
                 .collect();
 
-        System.out.println(w);
+        //System.out.println(w);
 
         List<Integer> l = Sequence.from(1, 2, 3).cycle().take(10).collect();
-        System.out.println(l);
+        //System.out.println(l);
+
+        Sequence.random().bind(0, 20).ints();
     }
 }

src/main/java/dev/mv/utilsx/async/AsyncEvent.java

@@ -1,11 +1,65 @@
 package dev.mv.utilsx.async;
 
-public class Signal {
+import dev.mv.utilsx.futures.*;
+import dev.mv.utilsx.generic.Null;
+
+import java.time.Duration;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.concurrent.atomic.AtomicInteger;
+
+public class Signal implements Wake {
+
+    final Mutex<Boolean> ready = new Mutex<>(false);
+    final CondVar condition = new CondVar(ready);
+    final List<Waker> wakers = new ArrayList<>(1);
+    final AtomicInteger waiting = new AtomicInteger(0);
+
+    public boolean ready() {
+        return ready.get();
+    }
+
+    public void await() {
+        ready.lock();
+        waiting.getAndIncrement();
+        while (!ready.getLocked()) {
+            condition.await();
+        }
+        if (waiting.decrementAndGet() == 0) {
+            ready.setLocked(false);
+        }
+        ready.unlock();
+    }
+
+    public void await(Duration timeout) {
+        ready.lock();
+        waiting.getAndIncrement();
+        while (!ready.getLocked()) {
+            condition.await(timeout);
+        }
+        if (waiting.decrementAndGet() == 0) {
+            ready.setLocked(false);
+        }
+        ready.unlock();
+    }
+
+    public void await(long timeoutMillis) {
+        await(Duration.ofMillis(timeoutMillis));
+    }
+
+    public Future<Null> awaitAsync() {
+        return new SignalFuture(this);
+    }
+
+    @Override
     public void wake() {
-        try {
-             notifyAll();
-        } catch (Exception e) {
-            throw new RuntimeException(e);
+        ready.lock();
+        ready.set(true);
+        for (Waker waker : wakers) {
+            waker.wake();
         }
+        wakers.clear();
+        condition.signalAll();
+        ready.unlock();
     }
 }