jadex.platform.service.execution

Class SyncExecutionService

java.lang.Object

jadex.bridge.service.BasicService

jadex.platform.service.execution.SyncExecutionService

All Implemented Interfaces:

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

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

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

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field and Description
protected jadex.commons.concurrent.Executor	executor The executor.
protected jadex.commons.future.Future<java.lang.Void>	idlefuture The idle future.
protected jadex.bridge.IInternalAccess	provider The provider.
protected java.util.Set<jadex.commons.concurrent.IExecutable>	queue The queue of tasks to be executed.
protected java.util.List<jadex.commons.future.Future<java.lang.Void>>	removedfut The removed listeners.
protected jadex.commons.concurrent.IExecutable	removedtask Flag that indicates that the current task has been removed.
protected SyncExecutionService.State	state The state of the service.
protected jadex.commons.concurrent.IExecutable	task The current task.

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
SyncExecutionService(jadex.bridge.IInternalAccess provider) Create a new synchronous executor service.
SyncExecutionService(jadex.bridge.IInternalAccess provider, java.util.Map<java.lang.String,java.lang.Object> properties) Create a new synchronous 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.
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 or waiting tasks.
jadex.commons.future.IFuture<java.lang.Void>	shutdownService() Shutdown the executor service.
jadex.commons.future.IFuture<java.lang.Void>	startService() Start the executor 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

queue

protected java.util.Set<jadex.commons.concurrent.IExecutable> queue

The queue of tasks to be executed.

executor

protected jadex.commons.concurrent.Executor executor

The executor.

idlefuture

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

The idle future.

state

protected SyncExecutionService.State state

The state of the service.

task

protected jadex.commons.concurrent.IExecutable task

The current task.

removedtask

protected jadex.commons.concurrent.IExecutable removedtask

Flag that indicates that the current task has been removed.

removedfut

protected java.util.List<jadex.commons.future.Future<java.lang.Void>> removedfut

The removed listeners.

provider

protected jadex.bridge.IInternalAccess provider

The provider.

Constructor Detail

SyncExecutionService

public SyncExecutionService(jadex.bridge.IInternalAccess provider)

Create a new synchronous executor service.

SyncExecutionService

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

Create a new synchronous executor service.

Method Detail

execute

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

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

Specified by:

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

Parameters:

task - The task to execute.

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.

getRunningTasks

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

Get the currently running or waiting tasks.

Specified by:

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

customIsValid

public boolean customIsValid()

Test if the service is valid.

Returns:

True, if service can be used.

startService

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

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

Specified by:

shutdownService in interface jadex.bridge.service.IInternalService

Overrides:

shutdownService in class jadex.bridge.service.BasicService

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