jadex.bridge.service.execution

Class SyncExecutionService

java.lang.Object

jadex.bridge.service.BasicService

jadex.bridge.service.execution.SyncExecutionService

All Implemented Interfaces:

IExecutionService, IInternalService, IService

public class SyncExecutionService
extends BasicService
implements IExecutionService

The synchronous execution service that executes all tasks in zero to one thread.

Field Summary

Fields inherited from interface jadex.bridge.service.IService

EMPTY_SERVICES

Constructor Summary

Constructors

Constructor and Description
SyncExecutionService(IServiceProvider provider) Create a new synchronous executor service.
SyncExecutionService(IServiceProvider provider, Map<String,Object> properties) Create a new synchronous 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.
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.
IFuture<Void>	startService() Start the executor 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

SyncExecutionService

public SyncExecutionService(IServiceProvider provider)

Create a new synchronous executor service.

SyncExecutionService

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

Create a new synchronous executor service.

Method Detail

execute

public void execute(IExecutable task)

Execute a task. Triggers the task to be executed in future.

Specified by:

execute in interface IExecutionService

Parameters:

task - The task to execute.

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.

Returns:

Future signaling cancellation.

getTasks

public IExecutable[] getTasks()

Get the currently running or waiting tasks.

Specified by:

getTasks in interface IExecutionService

customIsValid

public boolean customIsValid()

Test if the service is valid.

Returns:

True, if service can be used.

startService

public IFuture<Void> startService()

Start the executor service. Resumes all 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.

Specified by:

shutdownService in interface IInternalService

Overrides:

shutdownService in class BasicService

Returns:

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

getNextIdleFuture

public IFuture<Void> getNextIdleFuture()

Get the future indicating that executor is idle.

Specified by:

getNextIdleFuture in interface IExecutionService