Actually report Hz
This commit is contained in:
parent
fb7425c5fe
commit
d169c1277b
|
@ -19,6 +19,7 @@ public class Main implements IForwarder {
|
||||||
public final int _nActors;
|
public final int _nActors;
|
||||||
public final int _nRounds;
|
public final int _nRounds;
|
||||||
public int _remainingToReceive;
|
public int _remainingToReceive;
|
||||||
|
public long _startTime = 0;
|
||||||
|
|
||||||
public Main(int nActors, int nRounds) {
|
public Main(int nActors, int nRounds) {
|
||||||
this._nActors = nActors;
|
this._nActors = nActors;
|
||||||
|
@ -36,6 +37,7 @@ public class Main implements IForwarder {
|
||||||
_actors.add(a.asyncProxy(IForwarder.class));
|
_actors.add(a.asyncProxy(IForwarder.class));
|
||||||
}
|
}
|
||||||
Actor.log().info("Start");
|
Actor.log().info("Start");
|
||||||
|
this._startTime = System.currentTimeMillis();
|
||||||
_actors.forEach((a) -> a.handleMessage(0));
|
_actors.forEach((a) -> a.handleMessage(0));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -43,8 +45,11 @@ public class Main implements IForwarder {
|
||||||
public void handleMessage(int hopCount) {
|
public void handleMessage(int hopCount) {
|
||||||
this._remainingToReceive--;
|
this._remainingToReceive--;
|
||||||
if (this._remainingToReceive == 0) {
|
if (this._remainingToReceive == 0) {
|
||||||
|
long delta = System.currentTimeMillis() - this._startTime;
|
||||||
|
long nMessages = _nActors * _nRounds;
|
||||||
|
double hz = nMessages / (delta / 1000.0);
|
||||||
Actor.current().stop();
|
Actor.current().stop();
|
||||||
Actor.log().info("Stop after " + (_nActors * _nRounds) + " messages");
|
Actor.log().info("Stop after " + nMessages + " messages; " + hz + " Hz");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue