Simultaneous timer events

[mode89]

Hi :)

If I understand it correctly, for each timer event current Java implementation generates a separate transaction, inside send(). What if there are multiple events scheduled to the same point in time? Shouldn't their send()s, as well as TimerSystem.time.send(), be aggregated into a single transaction in order to guarantee coalescence?

[mode89]

Here is a test:

TimerSystem ts = new MillisecondsTimerSystem();
Cell<Long> time = ts.time;
List<Long> out = new ArrayList<>();
Transaction.runVoid(() -> {
    Long now = time.sample();
    Stream a1 = ts.at(new Cell(Optional.of(now + 100)));
    Stream a2 = ts.at(new Cell(Optional.of(now + 100)));
    Stream<Long> m = a1.orElse(a2);
    m.listen((Long t) -> {
        out.add(t);
    });
});
try { Thread.sleep(200); } catch (InterruptedException e) {}
assertEquals(1, out.size());

It starts two alarms that should trigger at the same point in time. The stream, produced by merging both alarms, should have only one event.

[jam40jeff]

Thanks for the test. I have fixed this in the C# and F# versions (but not pushed yet) and will try to take a look at the Java version soon.

[mode89]

Thanks :)

[jam40jeff]

This has been fixed in the C# and F# versions. I will leave it open until the Java version is fixed as well.