Ensures serial execution of submitted tasks.

An Executor that uses an internal SerializedInvoker to ensure that only one of the submitted tasks is running at any time.

Nested and Inner Type Summary

Modifier and Type	Class and Description
public static interface	SerializedExecutor.ErrorHandlingTask Error handling task If a submitted task implements this interface, it will be passed any exceptions thrown when running the task.

Modifier and Type	Field and Description
private final Executor	_executor
private final SerializedInvoker	_invoker

Constructor Summary

Access	Constructor and Description
public	SerializedExecutor()
public	SerializedExecutor(Executor executor)

Method Summary

Modifier and Type	Method and Description
public void	execute(Runnable The task to invoke task) Implements java.util.concurrent.Executor.execute. Arrange for a task to be executed, mutually excluded from other tasks.
public void	execute(Runnable... The tasks to invoke tasks) Arrange for tasks to be executed, mutually excluded from other tasks.
protected void	onError(Runnable task, Throwable t)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

_executor	back to summary
private final Executor _executor

_invoker	back to summary
private final SerializedInvoker _invoker

Constructor Detail

SerializedExecutor	back to summary
public SerializedExecutor()

SerializedExecutor	back to summary
public SerializedExecutor(Executor executor)

Method Detail

execute back to summary

execute	back to summary
public void execute(Runnable task) Implements java.util.concurrent.Executor.execute. Arrange for a task to be executed, mutually excluded from other tasks. This is equivalent to executing any `Runnable` returned from the internal `SerializedInvoker#offer(Runnable)` method. Parameters task:Runnable The task to invoke Annotations @Override

public void execute(Runnable task)

Implements java.util.concurrent.Executor.execute.

Arrange for a task to be executed, mutually excluded from other tasks. This is equivalent to executing any Runnable returned from the internal SerializedInvoker#offer(Runnable) method.

Parameters

task:Runnable: The task to invoke

Annotations

@Override

execute back to summary

execute	back to summary
public void execute(Runnable... tasks) Arrange for tasks to be executed, mutually excluded from other tasks. This is equivalent to executing any `Runnable` returned from the internal `SerializedInvoker#offer(Runnable)` method. Parameters tasks:Runnable[] The tasks to invoke

public void execute(Runnable... tasks)

Arrange for tasks to be executed, mutually excluded from other tasks. This is equivalent to executing any Runnable returned from the internal SerializedInvoker#offer(Runnable) method.

Parameters

tasks:Runnable[]: The tasks to invoke

onError	back to summary
protected void onError(Runnable task, Throwable t)

org.eclipse.jetty.util.thread back to summary

public Interface SerializedExecutor.ErrorHandlingTask

extends Runnable, Consumer<Throwable>

Error handling task

If a submitted task implements this interface, it will be passed any exceptions thrown when running the task.

Method Summary

Inherited from java.lang.Runnable:: run
Inherited from java.util.function.Consumer:: accept andThen

public Class SerializedExecutor

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

public Interface SerializedExecutor.ErrorHandlingTask

Method Summary