Package jadex.micro.taskdistributor

Class TaskDistributorAgent<R,T>

java.lang.Object

jadex.micro.taskdistributor.TaskDistributorAgent<R,T>

All Implemented Interfaces:

ITaskDistributor<R,T>

public class TaskDistributorAgent<R,T>
extends Object
implements ITaskDistributor<R,T>

Nested Class Summary

Nested classes/interfaces inherited from interface jadex.micro.taskdistributor.ITaskDistributor

ITaskDistributor.Task<T>

Field Summary

Fields

Modifier and Type	Field	Description
protected int	cnt
protected Map<String,jadex.future.Future<R>>	ongoingtasks
protected Queue<jadex.future.Future<ITaskDistributor.Task<T>>>	requestors
protected Queue<jadex.micro.taskdistributor.TaskDistributorAgent.TaskFuture<T,R>>	tasks

Constructor Summary

Constructors

Constructor	Description
TaskDistributorAgent()

Method Summary

Modifier and Type	Method	Description
jadex.future.IFuture<R>	publish(T task)	Publish a new task.
jadex.future.IFuture<ITaskDistributor.Task<T>>	requestNextTask()	Request a task.
jadex.future.IFuture<Void>	setTaskException(String id, Exception ex)	Set the exception of a task.
jadex.future.IFuture<Void>	setTaskResult(String id, R result)	Set the result of a task.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

tasks

protected Queue<jadex.micro.taskdistributor.TaskDistributorAgent.TaskFuture<T,R>> tasks

requestors

protected Queue<jadex.future.Future<ITaskDistributor.Task<T>>> requestors

ongoingtasks

protected Map<String,jadex.future.Future<R>> ongoingtasks

cnt

protected int cnt

Constructor Details

TaskDistributorAgent

public TaskDistributorAgent()

Method Details

publish

public jadex.future.IFuture<R> publish(T task)

Publish a new task.

Specified by:

publish in interface ITaskDistributor<R,T>

Parameters:

task - The task to publish.

setTaskResult

public jadex.future.IFuture<Void> setTaskResult(String id,
 R result)

Set the result of a task.

Specified by:

setTaskResult in interface ITaskDistributor<R,T>

Parameters:

id - The task id.

result - The result.

setTaskException

public jadex.future.IFuture<Void> setTaskException(String id,
 Exception ex)

Set the exception of a task.

Specified by:

setTaskException in interface ITaskDistributor<R,T>

Parameters:

id - The task id.

ex - The exception.

requestNextTask

public jadex.future.IFuture<ITaskDistributor.Task<T>> requestNextTask()

Request a task.

Specified by:

requestNextTask in interface ITaskDistributor<R,T>

Returns:

The next task (waits for a task).