cloud.orbit.actors.concurrent

Class WaitFreeExecutionSerializer

java.lang.Object

cloud.orbit.actors.concurrent.WaitFreeExecutionSerializer

All Implemented Interfaces:

ExecutionSerializer, Executor

public class WaitFreeExecutionSerializer
extends Object
implements ExecutionSerializer, Executor

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

Author:

Daniel Sperry

Constructor Summary

Constructors

Constructor and Description
WaitFreeExecutionSerializer(ExecutorService executorService)
WaitFreeExecutionSerializer(ExecutorService executorService, Object key)

Method Summary

Modifier and Type	Method and Description
void	execute(Runnable command)
<R> Task<R>	executeSerialized(Supplier<Task<R>> taskSupplier, int maxQueueSize)
boolean	isBusy()

Methods inherited from class java.lang.Object

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

Constructor Detail

WaitFreeExecutionSerializer

public WaitFreeExecutionSerializer(ExecutorService executorService)

WaitFreeExecutionSerializer

public WaitFreeExecutionSerializer(ExecutorService executorService,
                                   Object key)

Method Detail

executeSerialized

public <R> Task<R> executeSerialized(Supplier<Task<R>> taskSupplier,
                                     int maxQueueSize)

Specified by:

executeSerialized in interface ExecutionSerializer

isBusy

public boolean isBusy()

Specified by:

isBusy in interface ExecutionSerializer

execute

public void execute(Runnable command)

Specified by:

execute in interface Executor