jadex.commons.concurrent

Class Executor

java.lang.Object

jadex.commons.concurrent.Executor

All Implemented Interfaces:

Runnable

public class Executor
extends Object
implements Runnable

A helper class for running a single instance of code using the thread pool. The code to be executed has to be placed in the code() method. Once created, the execute() method may be called as often as desired. When no thread is currently executing the object, a new thread is used from the thread pool. Otherwise, the already existing thread continues execution. After shutdown() is called, the executor stops execution, even when execute() is called afterwards.

Field Summary

Fields

Modifier and Type	Field and Description
static ThreadLocal<Executor>	EXECUTOR The executor belonging to a thread.

Constructor Summary

Constructors

Constructor and Description
Executor(IThreadPool threadpool) Create an executor object.
Executor(IThreadPool threadpool, IExecutable executable) Create an executor object.

Method Summary

Methods

Modifier and Type	Method and Description
void	blockThread(Object monitor) Adjust to execution of current thread to be blocked.
boolean	execute() Make sure a thread is executing the code.
void	run() Execute the code.
void	setExecutable(IExecutable executable) Set the executable.
IFuture<Void>	shutdown() Shutdown the executor.
void	switchThread(Object monitor, Throwable t) Cease execution of the current thread and switch to another thread waiting for the given monitor.
String	toString() String representation.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

EXECUTOR

public static final ThreadLocal<Executor> EXECUTOR

The executor belonging to a thread.

Constructor Detail

Executor

public Executor(IThreadPool threadpool)

Create an executor object. Constructor for subclasses overriding the code() method.

Executor

public Executor(IThreadPool threadpool,
        IExecutable executable)

Create an executor object.

Method Detail

run

public void run()

Execute the code.

Specified by:

run in interface Runnable

execute

public boolean execute()

Make sure a thread is executing the code.

shutdown

public IFuture<Void> shutdown()

Shutdown the executor.

setExecutable

public void setExecutable(IExecutable executable)

Set the executable.

Parameters:

executable - The executable.

switchThread

public void switchThread(Object monitor,
                Throwable t)

Cease execution of the current thread and switch to another thread waiting for the given monitor.

Parameters:

monitor - The monitor to be notified.

t - The exception to be thrown on the unblocked thread (null for continuing normal execution).

blockThread

public void blockThread(Object monitor)

Adjust to execution of current thread to be blocked.

toString

public String toString()

String representation.

Overrides:

toString in class Object