org.eclipse.californium.elements.util

Class SerialExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

org.eclipse.californium.elements.util.SerialExecutor

All Implemented Interfaces:

Executor, ExecutorService

public class SerialExecutor
extends AbstractExecutorService

Serial executor. Serialize job execution before passing the jobs to a provided executor.

Constructor Summary

Constructors

Constructor and Description
SerialExecutor(Executor executor) Create serial executor

Method Summary

Methods

Modifier and Type	Method and Description
void	assertOwner() Assert, that the current thread executes the currentlyExecutedJob.
boolean	awaitTermination(long timeout, TimeUnit unit)
boolean	checkOwner() Check, if current thread executes the currentlyExecutedJob.
static SerialExecutor	create(Executor executor) Create serial executor from provided executor.
void	execute(Runnable command)
boolean	isShutdown()
boolean	isTerminated()
void	shutdown() .
List<Runnable>	shutdownNow() .
int	shutdownNow(Collection<Runnable> jobs) Shutdown this executor and add all pending task from tasks to the provided collection.

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor, submit, submit, submit

Methods inherited from class java.lang.Object

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

Constructor Detail

SerialExecutor

public SerialExecutor(Executor executor)

Create serial executor

Parameters:

executor - target executor. If null, the executor is shutdown.

Method Detail

execute

public void execute(Runnable command)

assertOwner

public void assertOwner()

Assert, that the current thread executes the currentlyExecutedJob.

Throws:

ConcurrentModificationException - if current thread doesn't execute the currentlyExecutedJob.

checkOwner

public boolean checkOwner()

Check, if current thread executes the currentlyExecutedJob.

Returns:

true, if current thread executes the currentlyExecutedJob, false, otherwise.

shutdown

public final void shutdown()

. Doesn't shutdown the target executor executor.

shutdownNow

public final List<Runnable> shutdownNow()

. Doesn't shutdown the target executor executor.

See Also:

shutdownNow(Collection)

shutdownNow

public int shutdownNow(Collection<Runnable> jobs)

Shutdown this executor and add all pending task from tasks to the provided collection.

Parameters:

jobs - collection to add pending jobs.

Returns:

number of added jobs

See Also:

shutdownNow()

isShutdown

public boolean isShutdown()

isTerminated

public boolean isTerminated()

awaitTermination

public boolean awaitTermination(long timeout,
                       TimeUnit unit)
                         throws InterruptedException

Throws:

InterruptedException

create

public static SerialExecutor create(Executor executor)

Create serial executor from provided executor.

Parameters:

executor - target executor. if null, no serial executor is created.

Returns:

created serial executor, or null, if provided executor is null.