Async Demo

gistfile1.java

Watch w = Watch.start();
int msgs = 10_000_000;
AtomicInteger received = new AtomicInteger();
for (int i = 0; i < msgs; i++) {
    Async.defaultExecutor().start(() -> {
        Async.defaultExecutor().start(() -> {
            int numReceived = received.incrementAndGet();
            if (numReceived % 500_000 == 0) {
                System.out.println(numReceived + " " + w.duration());
            }
        }).execute();
    }).execute();
}

while (received.get() < msgs) {
    Wait.millis(100);
}

System.out.println(w.duration());