jadex.bridge.service.execution

Class AsyncExecutionService

java.lang.Object

jadex.bridge.service.BasicService

jadex.bridge.service.execution.AsyncExecutionService

All Implemented Interfaces:

IExecutionService, IInternalService, IService

public class AsyncExecutionService
extends BasicService
implements IExecutionService

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

Field Summary

Fields inherited from interface jadex.bridge.service.IService

EMPTY_SERVICES

Constructor Summary

Constructors

Constructor and Description
AsyncExecutionService(IServiceProvider provider) Create a new asynchronous executor service.
AsyncExecutionService(IServiceProvider provider, Map<String,Object> properties) Create a new asynchronous executor service.

Method Summary

Methods

Modifier and Type	Method and Description
IFuture<Void>	cancel(IExecutable task) Cancel a task.
boolean	customIsValid() Test if the service is valid.
void	execute(IExecutable task) Execute a task in its own thread.
IFuture<Void>	getNextIdleFuture() Get the future indicating that executor is idle.
IExecutable[]	getTasks() Get the currently running or waiting tasks.
IFuture<Void>	shutdownService() Shutdown the executor service. // todo: make callable more than once
IFuture<Void>	startService() Start the execution service.

Methods inherited from class jadex.bridge.service.BasicService

createServiceIdentifier, createServiceIdentifier, equals, generateServiceName, getPropertyMap, getServiceIdentifier, isValid, setPropertyMap

Methods inherited from class java.lang.Object

getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface jadex.bridge.service.IService

getPropertyMap, getServiceIdentifier, isValid

Constructor Detail

AsyncExecutionService

public AsyncExecutionService(IServiceProvider provider)

Create a new asynchronous executor service.

AsyncExecutionService

public AsyncExecutionService(IServiceProvider provider,
                     Map<String,Object> properties)

Create a new asynchronous executor service.

Method Detail

execute

public void execute(IExecutable task)

Execute a task in its own thread.

Specified by:

execute in interface IExecutionService

Parameters:

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

cancel

public IFuture<Void> cancel(IExecutable task)

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

Specified by:

cancel in interface IExecutionService

Parameters:

task - The task to execute.

listener - The listener.

Returns:

Future signaling cancellation.

getTasks

public IExecutable[] getTasks()

Get the currently running or waiting tasks.

Specified by:

getTasks in interface IExecutionService

startService

public IFuture<Void> startService()

Start the execution service. Resumes all scheduled tasks.

Specified by:

startService in interface IInternalService

Overrides:

startService in class BasicService

Returns:

A future that is done when the service has completed starting.

shutdownService

public IFuture<Void> shutdownService()

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

Specified by:

shutdownService in interface IInternalService

Overrides:

shutdownService in class BasicService

Returns:

A future that is done when the service has completed its shutdown.

customIsValid

public boolean customIsValid()

Test if the service is valid.

Returns:

True, if service can be used.

getNextIdleFuture

public IFuture<Void> getNextIdleFuture()

Get the future indicating that executor is idle.

Specified by:

getNextIdleFuture in interface IExecutionService