jadex.platform.service.threadpool

Class ThreadPoolService

java.lang.Object

jadex.bridge.service.BasicService

jadex.platform.service.threadpool.ThreadPoolService

All Implemented Interfaces:

jadex.bridge.service.IInternalService, jadex.bridge.service.IService, jadex.bridge.service.types.threadpool.IDaemonThreadPoolService, jadex.bridge.service.types.threadpool.IThreadPoolService, jadex.commons.concurrent.IThreadPool

public class ThreadPoolService
extends jadex.bridge.service.BasicService
implements jadex.bridge.service.types.threadpool.IThreadPoolService, jadex.bridge.service.types.threadpool.IDaemonThreadPoolService

Service wrapper for a threadpool.

Field Summary

Fields

Modifier and Type	Field and Description
protected jadex.commons.concurrent.IThreadPool	threadpool The threadpool.

Fields inherited from class jadex.bridge.service.BasicService

idcnt, impltype, internalaccess, providerid, shutdowned, sid, started, type

Fields inherited from interface jadex.bridge.service.IService

EMPTY_SERVICES

Constructor Summary

Constructors

Constructor and Description
ThreadPoolService(jadex.commons.concurrent.IThreadPool threadpool, jadex.bridge.IComponentIdentifier provider) Create a new threadpool service.

Method Summary

Modifier and Type	Method and Description
void	addFinishListener(jadex.commons.IChangeListener<java.lang.Void> listener) Add a finished 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.
jadex.commons.future.IFuture<java.lang.Void>	shutdownService() Shutdown the service.

Methods inherited from class jadex.bridge.service.BasicService

createServiceIdentifier, createServiceIdentifier, equals, generateServiceName, getInterfaceType, getInternalAccess, getMethodTimeout, getPropertyMap, getProviderId, getServiceIdentifier, hashCode, initNFProperties, isValid, setComponentAccess, setPropertyMap, startService, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

threadpool

protected jadex.commons.concurrent.IThreadPool threadpool

The threadpool.

Constructor Detail

ThreadPoolService

public ThreadPoolService(jadex.commons.concurrent.IThreadPool threadpool,
                         jadex.bridge.IComponentIdentifier provider)

Create a new threadpool service.

Method Detail

shutdownService

public jadex.commons.future.IFuture<java.lang.Void> shutdownService()

Shutdown the service.

Specified by:

shutdownService in interface jadex.bridge.service.IInternalService

Overrides:

shutdownService in class jadex.bridge.service.BasicService

Parameters:

listener - The listener.

execute

public void execute(java.lang.Runnable task)

Execute a task in its own thread.

Specified by:

execute in interface jadex.commons.concurrent.IThreadPool

Parameters:

task - The task to execute.

dispose

public void dispose()

Shutdown the thread pool.

Specified by:

dispose in interface jadex.commons.concurrent.IThreadPool

isRunning

public boolean isRunning()

Test if the thread pool is running.

Specified by:

isRunning in interface jadex.commons.concurrent.IThreadPool

addFinishListener

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

Add a finished listener.

Specified by:

addFinishListener in interface jadex.commons.concurrent.IThreadPool