Package jadex.future

Class ThreadSuspendable

java.lang.Object

jadex.future.ThreadLocalTransferHelper

jadex.future.ThreadSuspendable

All Implemented Interfaces:

ISuspendable

public class ThreadSuspendable
extends ThreadLocalTransferHelper
implements ISuspendable

Suspendable for threads.

Field Summary

Fields

Modifier and Type	Field	Description
protected IFuture<?>	future	The future.
protected ReentrantLock	lock	Use reentrant lock/condition instead of synchronized/wait/notify to avoid pinning when using virtual threads.
protected boolean	resumed	The resumed flag to differentiate from timeout.
protected Condition	wait
static final Map<Thread,Future<?>>	WAITING_THREADS	Threads waiting due to thread suspendable.

Fields inherited from class jadex.future.ThreadLocalTransferHelper

THREADLOCALS, vals

Fields inherited from interface jadex.future.ISuspendable

SUSPENDABLE

Constructor Summary

Constructors

Constructor	Description
ThreadSuspendable()

Method Summary

Modifier and Type	Method	Description
protected long	getDefaultTimeout()	Get the default timeout.
IFuture<?>	getFuture()	Get the future if currently suspended, null otherwise.
ReentrantLock	getLock()	Return the lock for internal synchronization.
void	resume(Future<?> future)	Resume the execution of the suspendable.
void	suspend(Future<?> future, long timeout, boolean realtime)	Suspend the execution of the suspendable.

Methods inherited from class jadex.future.ThreadLocalTransferHelper

addThreadLocal, afterSwitch, beforeSwitch, removeThreadLocal, restoreValues, saveValues

Methods inherited from class java.lang.Object

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

Field Details

WAITING_THREADS

public static final Map<Thread,Future<?>> WAITING_THREADS

Threads waiting due to thread suspendable.

future

protected IFuture<?> future

The future.

resumed

protected boolean resumed

The resumed flag to differentiate from timeout.

lock

protected ReentrantLock lock

Use reentrant lock/condition instead of synchronized/wait/notify to avoid pinning when using virtual threads.

wait

protected Condition wait

Constructor Details

ThreadSuspendable

public ThreadSuspendable()

Method Details

suspend

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

Suspend the execution of the suspendable.

Specified by:

suspend in interface ISuspendable

Parameters:

timeout - The timeout.

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

future - The future to wait for.

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.

getLock

public ReentrantLock getLock()

Return the lock for internal synchronization.

Specified by:

getLock in interface ISuspendable

getFuture

public IFuture<?> getFuture()

Get the future if currently suspended, null otherwise.

Specified by:

getFuture in interface ISuspendable

getDefaultTimeout

protected long getDefaultTimeout()

Get the default timeout.

Returns:

The default timeout (-1 for none).