jadex.bridge.service.component

Class ComponentSuspendable

java.lang.Object

jadex.commons.future.ThreadLocalTransferHelper

jadex.bridge.service.component.ComponentSuspendable

All Implemented Interfaces:

ISuspendable

public class ComponentSuspendable
extends ThreadLocalTransferHelper
implements ISuspendable

Allow waiting for futures by blocking a component.

Field Summary

Fields

Modifier and Type	Field and Description
protected IInternalAccess	agent The component adapter.
static java.lang.ThreadLocal<ComponentSuspendable>	COMSUPS The component suspendables.
protected Future<?>	future The current future.
protected java.util.Map<java.lang.ThreadLocal<java.lang.Object>,java.lang.Object>	vals The thread locals.

Fields inherited from class jadex.commons.future.ThreadLocalTransferHelper

THREADLOCALS

Fields inherited from interface jadex.commons.future.ISuspendable

SUSPENDABLE

Constructor Summary

Constructors

Constructor and Description
ComponentSuspendable(IInternalAccess agent) Create a component suspendable.

Method Summary

Modifier and Type	Method and Description
long	getDefaultTimeout() Get the default timeout.
Future<?>	getFuture() Get the future.
java.lang.Object	getMonitor() Get the monitor for waiting.
void	resume(Future<?> future) Resume the execution of the suspendable.
void	suspend(Future<?> future, long timeout, boolean realtime) Suspend the execution of the suspendable.
java.lang.String	toString() Get the string representation.

Methods inherited from class jadex.commons.future.ThreadLocalTransferHelper

addThreadLocal, afterSwitch, beforeSwitch, removeThreadLocal, restoreValues, saveValues

Methods inherited from class java.lang.Object

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

Field Detail

COMSUPS

public static final java.lang.ThreadLocal<ComponentSuspendable> COMSUPS

The component suspendables.

agent

protected IInternalAccess agent

The component adapter.

future

protected Future<?> future

The current future.

vals

protected java.util.Map<java.lang.ThreadLocal<java.lang.Object>,java.lang.Object> vals

The thread locals.

Constructor Detail

ComponentSuspendable

public ComponentSuspendable(IInternalAccess agent)

Create a component suspendable.

Method Detail

suspend

public void suspend(Future<?> future,
                    long timeout,
                    boolean realtime)

Suspend the execution of the suspendable.

Specified by:

suspend in interface ISuspendable

Parameters:

future - The future to wait for.

timeout - The timeout.

realtime - Flag if timeout is realtime (in contrast to simulation time).

resume

public void resume(Future<?> future)

Resume the execution of the suspendable.

Specified by:

resume in interface ISuspendable

Parameters:

future - The future that issues the resume.

getMonitor

public java.lang.Object getMonitor()

Get the monitor for waiting.

Specified by:

getMonitor in interface ISuspendable

Returns:

The monitor.

getFuture

public Future<?> getFuture()

Get the future.

Returns:

The future.

getDefaultTimeout

public long getDefaultTimeout()

Get the default timeout.

Returns:

The default timeout (-1 for none).

toString

public java.lang.String toString()

Get the string representation.

Overrides:

toString in class java.lang.Object