fi.jumi.actors

Class SingleThreadedActors

java.lang.Object

fi.jumi.actors.Actors

fi.jumi.actors.SingleThreadedActors

@NotThreadSafe
public class SingleThreadedActors
extends Actors

Single-threaded actors container for testing. The ActorThreads are not backed by real threads - instead they will process messages when the processEventsUntilIdle() method is called.

Constructor Summary

Constructors

Constructor and Description
SingleThreadedActors(EventizerProvider eventizerProvider, FailureHandler failureHandler, MessageListener messageListener)

Method Summary

Methods

Modifier and Type	Method and Description
Executor	getExecutor() Returns an asynchronous Executor which works the same way as all the actors in this container.
void	processEventsUntilIdle() Processes in the current thread all messages which were sent to actors.

Methods inherited from class fi.jumi.actors.Actors

startActorThread

Methods inherited from class java.lang.Object

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

Constructor Detail

SingleThreadedActors

public SingleThreadedActors(EventizerProvider eventizerProvider,
                    FailureHandler failureHandler,
                    MessageListener messageListener)

Method Detail

processEventsUntilIdle

public void processEventsUntilIdle()

Processes in the current thread all messages which were sent to actors. The order of processing messages is deterministic. Will block until all messages have been processed and nobody is sending more messages.

When using CrashEarlyFailureHandler, will rethrow uncaught exceptions from actors to the caller of this method.

getExecutor

public Executor getExecutor()

Returns an asynchronous Executor which works the same way as all the actors in this container. Useful in tests to have asynchrony without the non-determinism of real threads.

See Also:

processEventsUntilIdle()