jadex.commons.concurrent.java5

Class JavaThreadPool

java.lang.Object

jadex.commons.concurrent.java5.JavaThreadPool

All Implemented Interfaces:

IThreadPool

public class JavaThreadPool
extends java.lang.Object
implements IThreadPool

A thread pool based on the java.util.concurrent package.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.ExecutorService	executor The executor service.
protected boolean	finished Boolean if already finished.
protected java.util.List<IChangeListener<java.lang.Void>>	listeners The finished listeners.

Constructor Summary

Constructors

Constructor and Description
JavaThreadPool() Create a new ThreadPool5.

Method Summary

Modifier and Type	Method and Description
void	addFinishListener(IChangeListener<java.lang.Void> listener) Add a finish listener;
void	dispose() Shutdown the thread pool.
void	execute(java.lang.Runnable task) Execute a task in its own thread.
boolean	isRunning() Test if the thread pool is running.
protected void	notifyFinishListeners() Notify the finish listeners.

Methods inherited from class java.lang.Object

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

Field Detail

executor

protected java.util.concurrent.ExecutorService executor

The executor service.

listeners

protected java.util.List<IChangeListener<java.lang.Void>> listeners

The finished listeners.

finished

protected boolean finished

Boolean if already finished.

Constructor Detail

JavaThreadPool

public JavaThreadPool()

Create a new ThreadPool5.

Method Detail

execute

public void execute(java.lang.Runnable task)

Execute a task in its own thread.

Specified by:

execute in interface IThreadPool

Parameters:

task - The task to execute.

dispose

public void dispose()

Shutdown the thread pool.

Specified by:

dispose in interface IThreadPool

isRunning

public boolean isRunning()

Test if the thread pool is running.

Specified by:

isRunning in interface IThreadPool

addFinishListener

public void addFinishListener(IChangeListener<java.lang.Void> listener)

Add a finish listener;

Specified by:

addFinishListener in interface IThreadPool

notifyFinishListeners

protected void notifyFinishListeners()

Notify the finish listeners.