cloud.orbit.actors.concurrent

Class WaitFreeMultiExecutionSerializer<T>

java.lang.Object

cloud.orbit.actors.concurrent.WaitFreeMultiExecutionSerializer<T>

All Implemented Interfaces:

MultiExecutionSerializer<T>

public class WaitFreeMultiExecutionSerializer<T>
extends Object
implements MultiExecutionSerializer<T>

Ensures that only a single task is executed at each time per key.

Author:

Daniel Sperry

Constructor Summary

Constructors

Constructor and Description
WaitFreeMultiExecutionSerializer()
WaitFreeMultiExecutionSerializer(ExecutorService executor)

Method Summary

Modifier and Type	Method and Description
WaitFreeExecutionSerializer	getSerializer(T key)
boolean	isBusy()
<R> Task<R>	offerJob(T key, Supplier<Task<R>> job, int maxQueueSize) Only accepts if the queue size is not exceeded.
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

WaitFreeMultiExecutionSerializer

public WaitFreeMultiExecutionSerializer()

WaitFreeMultiExecutionSerializer

public WaitFreeMultiExecutionSerializer(ExecutorService executor)

Method Detail

getSerializer

public WaitFreeExecutionSerializer getSerializer(T key)

offerJob

public <R> Task<R> offerJob(T key,
                            Supplier<Task<R>> job,
                            int maxQueueSize)

Only accepts if the queue size is not exceeded.

Specified by:

offerJob in interface MultiExecutionSerializer<T>

Returns:

true if the task was accepted.

shutdown

public void shutdown()

Specified by:

shutdown in interface MultiExecutionSerializer<T>

isBusy

public boolean isBusy()

Specified by:

isBusy in interface MultiExecutionSerializer<T>