syndicate-lang
/
syndicate-java
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Start timing after all peer-setting has been done

This commit is contained in:
Tony Garnock-Jones 2023-10-28 13:49:49 +02:00
parent 637f1da5f4
commit cb3fd44529
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/test/java/org/syndicate_lang/actors/example/example2/Main.java
View File

@ -45,10 +45,11 @@ public class Main extends Entity {
previous = current;
}
t.message_(_forwarders.get(0), new IForwarder.SetPeer(_forwarders.get(_nActors - 1)));
t.log().info("Start");
this._startTime = System.currentTimeMillis();
t.later(t0 ->
_forwarders.forEach(a -> t0.message_(a, new IForwarder.HandleMessage(0))));
t.later(t0 -> {
t.log().info("Start");
this._startTime = System.currentTimeMillis();
_forwarders.forEach(a -> t0.message_(a, new IForwarder.HandleMessage(0)));
});
}
@Override