Converted tabs to spaces.
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
This commit is contained in:
parent
4d649c3903
commit
7db3f62ff5
2 changed files with 2 additions and 2 deletions
|
|
@ -127,7 +127,7 @@ class TellThroughputSeparateDispatchersPerformanceSpec extends PerformanceSpec {
|
||||||
yield system.actorOf(Props(new Destination).withDispatcher(clientDispatcher))
|
yield system.actorOf(Props(new Destination).withDispatcher(clientDispatcher))
|
||||||
val clients = for ((dest, j) ← destinations.zipWithIndex)
|
val clients = for ((dest, j) ← destinations.zipWithIndex)
|
||||||
yield system.actorOf(Props(new Client(dest, latch, repeatsPerClient)).withDispatcher(clientDispatcher))
|
yield system.actorOf(Props(new Client(dest, latch, repeatsPerClient)).withDispatcher(clientDispatcher))
|
||||||
*/
|
*/
|
||||||
|
|
||||||
val start = System.nanoTime
|
val start = System.nanoTime
|
||||||
clients.foreach(_ ! Run)
|
clients.foreach(_ ! Run)
|
||||||
|
|
|
||||||
|
|
@ -115,7 +115,7 @@ public class Pi {
|
||||||
for (int i = 0; i < nrOfWorkers; i++) add(getContext().actorOf(Worker.class));
|
for (int i = 0; i < nrOfWorkers; i++) add(getContext().actorOf(Worker.class));
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
// FIXME routers are intended to be used like this
|
// FIXME routers are intended to be used like this
|
||||||
RoutedProps props = new RoutedProps(routerCreator, new LocalConnectionManager(actors), new akka.actor.Timeout(-1), true);
|
RoutedProps props = new RoutedProps(routerCreator, new LocalConnectionManager(actors), new akka.actor.Timeout(-1), true);
|
||||||
router = new RoutedActorRef(getContext().system(), props, (InternalActorRef) getSelf(), "pi");
|
router = new RoutedActorRef(getContext().system(), props, (InternalActorRef) getSelf(), "pi");
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue