fi.jumi.actors.workers

Class WorkerCounter

java.lang.Object

fi.jumi.actors.workers.WorkerCounter

All Implemented Interfaces:

Executor

@ThreadSafe
public class WorkerCounter
extends Object
implements Executor

Fires a callback after a transitive bunch of worker threads are finished.

Constructor Summary

Constructors

Constructor and Description
WorkerCounter(Executor realExecutor)

Method Summary

Methods

Modifier and Type	Method and Description
void	afterPreviousWorkersFinished(ActorRef<WorkerListener> onFinished) Calls WorkerListener.onAllWorkersFinished() on the specified callback after all commands previously submitted to execute(Runnable), and recursively all commands which they submitted to execute(Runnable), have finished executing.
void	execute(Runnable command)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WorkerCounter

public WorkerCounter(Executor realExecutor)

Method Detail

execute

public void execute(Runnable command)

Specified by:

execute in interface Executor

afterPreviousWorkersFinished

public void afterPreviousWorkersFinished(ActorRef<WorkerListener> onFinished)

Calls WorkerListener.onAllWorkersFinished() on the specified callback after all commands previously submitted to execute(Runnable), and recursively all commands which they submitted to execute(Runnable), have finished executing.