jadex.platform.service.execution

Class AsyncExecutionService

java.lang.Object

jadex.bridge.service.BasicService

jadex.platform.service.execution.AsyncExecutionService

All Implemented Interfaces:

jadex.bridge.service.IInternalService, jadex.bridge.service.IService, jadex.bridge.service.types.execution.IExecutionService

public class AsyncExecutionService
extends jadex.bridge.service.BasicService
implements jadex.bridge.service.types.execution.IExecutionService

The asynchronous executor service that executes all tasks in separate executors.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AsyncExecutionService.State The possible states of the service.

Field Summary

Fields

Modifier and Type	Field and Description
protected jadex.bridge.IInternalAccess	component The component.
protected java.util.Map<jadex.commons.concurrent.IExecutable,jadex.commons.concurrent.Executor>	executors The currently waiting tasks (task->executor).
protected jadex.commons.future.Future<java.lang.Void>	idlefuture The idle future.
protected java.util.Map<jadex.commons.concurrent.IExecutable,jadex.commons.concurrent.Executor>	runningexes The running (i.e.
protected AsyncExecutionService.State	state The state.
protected jadex.bridge.service.types.threadpool.IThreadPoolService	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
AsyncExecutionService(jadex.bridge.IInternalAccess component) Create a new asynchronous executor service.
AsyncExecutionService(jadex.bridge.IInternalAccess component, java.util.Map<java.lang.String,java.lang.Object> properties) Create a new asynchronous executor service.

Method Summary

Modifier and Type	Method and Description
jadex.commons.future.IFuture<java.lang.Void>	cancel(jadex.commons.concurrent.IExecutable task) Cancel a task.
boolean	customIsValid() Test if the service is valid.
void	execute(jadex.commons.concurrent.IExecutable task) Execute a task in its own thread.
jadex.commons.future.IFuture<java.lang.Void>	getNextIdleFuture() Get the future indicating that executor is idle.
jadex.commons.concurrent.IExecutable[]	getRunningTasks() Get the currently running tasks.
jadex.commons.future.IFuture<java.lang.Void>	shutdownService() Shutdown the executor service.
jadex.commons.future.IFuture<java.lang.Void>	startService() Start the execution service.

Methods inherited from class jadex.bridge.service.BasicService

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

Methods inherited from class java.lang.Object

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

Field Detail

threadpool

protected jadex.bridge.service.types.threadpool.IThreadPoolService threadpool

The threadpool.

executors

protected java.util.Map<jadex.commons.concurrent.IExecutable,jadex.commons.concurrent.Executor> executors

The currently waiting tasks (task->executor).

idlefuture

protected jadex.commons.future.Future<java.lang.Void> idlefuture

The idle future.

state

protected AsyncExecutionService.State state

The state.

component

protected jadex.bridge.IInternalAccess component

The component.

runningexes

protected java.util.Map<jadex.commons.concurrent.IExecutable,jadex.commons.concurrent.Executor> runningexes

The running (i.e. non-blocked) executors.

Constructor Detail

AsyncExecutionService

public AsyncExecutionService(jadex.bridge.IInternalAccess component)

Create a new asynchronous executor service.

AsyncExecutionService

public AsyncExecutionService(jadex.bridge.IInternalAccess component,
                             java.util.Map<java.lang.String,java.lang.Object> properties)

Create a new asynchronous executor service.

Method Detail

execute

public void execute(jadex.commons.concurrent.IExecutable task)

Execute a task in its own thread.

Specified by:

execute in interface jadex.bridge.service.types.execution.IExecutionService

Parameters:

task - The task to execute. (called from arbitrary threads)

cancel

public jadex.commons.future.IFuture<java.lang.Void> cancel(jadex.commons.concurrent.IExecutable task)

Cancel a task. Triggers the task to be not executed in future.

Specified by:

cancel in interface jadex.bridge.service.types.execution.IExecutionService

Parameters:

task - The task to execute.

listener - The listener.

getRunningTasks

public jadex.commons.concurrent.IExecutable[] getRunningTasks()

Get the currently running tasks.

Specified by:

getRunningTasks in interface jadex.bridge.service.types.execution.IExecutionService

startService

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

Start the execution service. Resumes all scheduled tasks.

Specified by:

startService in interface jadex.bridge.service.IInternalService

Overrides:

startService in class jadex.bridge.service.BasicService

shutdownService

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

Shutdown the executor service. // todo: make callable more than once

Specified by:

shutdownService in interface jadex.bridge.service.IInternalService

Overrides:

shutdownService in class jadex.bridge.service.BasicService

customIsValid

public boolean customIsValid()

Test if the service is valid.

Returns:

True, if service can be used.

getNextIdleFuture

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

Get the future indicating that executor is idle.

Specified by:

getNextIdleFuture in interface jadex.bridge.service.types.execution.IExecutionService