Class RootWorkflowThreadImpl

java.lang.Object

io.temporal.internal.sync.RootWorkflowThreadImpl

All Implemented Interfaces:

WorkflowThread, CancellationScope, Runnable

public class RootWorkflowThreadImpl
extends Object

Method Summary

Modifier and Type	Method	Description
void	addStackTrace(StringBuilder result)
void	cancel()	Cancels the scope as well as all its children
void	cancel(String reason)	Cancels the scope as well as all its children.
void	evaluateInCoroutineContext(Functions.Proc1<String> function)	Evaluates function in the threadContext of the coroutine without unblocking it.
void	exitThread()
String	getCancellationReason()
Promise<String>	getCancellationRequest()	Use this promise to perform cancellation of async operations.
long	getId()
String	getName()
int	getPriority()
io.temporal.internal.sync.DeterministicRunnerImpl	getRunner()
String	getStackTrace()
<T> Optional<Optional<T>>	getThreadLocal(WorkflowThreadLocalInternal<T> key)	Retrieve data from thread locals.
Throwable	getUnhandledException()
io.temporal.internal.sync.SyncWorkflowContext	getWorkflowContext()
io.temporal.internal.sync.WorkflowThreadContext	getWorkflowThreadContext()
boolean	isCancelRequested()	Is scope was asked to cancel through CancellationScope.cancel() or by a parent scope.
boolean	isDetached()	When set to false parent thread cancellation causes this one to get canceled automatically.
boolean	isDone()
boolean	isStarted()
NonIdempotentHandle	lockDeadlockDetector()	Disables deadlock detector on this thread
void	run()
boolean	runUntilBlocked(long deadlockDetectionTimeoutMs)
void	setName(String name)
<T> void	setThreadLocal(WorkflowThreadLocalInternal<T> key, T value)
void	start()
Future<?>	stopNow()	Interrupt coroutine by throwing DestroyWorkflowThreadError from an await method it is blocked on and return underlying Future to be waited on.
void	yield(String reason, Supplier<Boolean> unblockCondition)

Methods inherited from class java.lang.Object

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

Method Details

yield

public void yield(String reason,
 Supplier<Boolean> unblockCondition)
           throws DestroyWorkflowThreadError

Specified by:

yield in interface WorkflowThread

Throws:

DestroyWorkflowThreadError

run

public void run()

Specified by:

run in interface Runnable

isDetached

public boolean isDetached()

Description copied from interface: CancellationScope

When set to false parent thread cancellation causes this one to get canceled automatically. When set to true only call to CancellationScope.cancel() leads to this scope cancellation.

Specified by:

isDetached in interface CancellationScope

cancel

public void cancel()

Description copied from interface: CancellationScope

Cancels the scope as well as all its children

Specified by:

cancel in interface CancellationScope

cancel

public void cancel(String reason)

Description copied from interface: CancellationScope

Cancels the scope as well as all its children.

Specified by:

cancel in interface CancellationScope

Parameters:

reason - human-readable reason for the cancellation. Becomes message of the CanceledException thrown.

getCancellationReason

public String getCancellationReason()

Specified by:

getCancellationReason in interface CancellationScope

isCancelRequested

public boolean isCancelRequested()

Description copied from interface: CancellationScope

Is scope was asked to cancel through CancellationScope.cancel() or by a parent scope.

Specified by:

isCancelRequested in interface CancellationScope

Returns:

whether request is canceled or not.

getCancellationRequest

public Promise<String> getCancellationRequest()

Description copied from interface: CancellationScope

Use this promise to perform cancellation of async operations.

Specified by:

getCancellationRequest in interface CancellationScope

Returns:

promise that becomes ready when scope is canceled. It contains reason value or null if none was provided.

start

public void start()

Specified by:

start in interface WorkflowThread

isStarted

public boolean isStarted()

Specified by:

isStarted in interface WorkflowThread

getWorkflowThreadContext

public io.temporal.internal.sync.WorkflowThreadContext getWorkflowThreadContext()

Specified by:

getWorkflowThreadContext in interface WorkflowThread

getRunner

public io.temporal.internal.sync.DeterministicRunnerImpl getRunner()

Specified by:

getRunner in interface WorkflowThread

getWorkflowContext

public io.temporal.internal.sync.SyncWorkflowContext getWorkflowContext()

Specified by:

getWorkflowContext in interface WorkflowThread

setName

public void setName(String name)

Specified by:

setName in interface WorkflowThread

getName

public String getName()

Specified by:

getName in interface WorkflowThread

getId

public long getId()

Specified by:

getId in interface WorkflowThread

getPriority

public int getPriority()

Specified by:

getPriority in interface WorkflowThread

runUntilBlocked

public boolean runUntilBlocked(long deadlockDetectionTimeoutMs)

Specified by:

runUntilBlocked in interface WorkflowThread

Parameters:

deadlockDetectionTimeoutMs - maximum time in milliseconds the thread can run before calling yield.

Returns:

true if coroutine made some progress.

lockDeadlockDetector

public NonIdempotentHandle lockDeadlockDetector()

Description copied from interface: WorkflowThread

Disables deadlock detector on this thread

Specified by:

lockDeadlockDetector in interface WorkflowThread

Returns:

a handle that must be used to unlock the deadlock detector back

isDone

public boolean isDone()

Specified by:

isDone in interface WorkflowThread

getUnhandledException

public Throwable getUnhandledException()

Specified by:

getUnhandledException in interface WorkflowThread

evaluateInCoroutineContext

public void evaluateInCoroutineContext(Functions.Proc1<String> function)

Evaluates function in the threadContext of the coroutine without unblocking it. Used to get current coroutine status, like stack trace.

Parameters:

function - Parameter is reason for current goroutine blockage.

stopNow

public Future<?> stopNow()

Interrupt coroutine by throwing DestroyWorkflowThreadError from an await method it is blocked on and return underlying Future to be waited on.

Specified by:

stopNow in interface WorkflowThread

addStackTrace

public void addStackTrace(StringBuilder result)

Specified by:

addStackTrace in interface WorkflowThread

exitThread

public void exitThread()

Specified by:

exitThread in interface WorkflowThread

setThreadLocal

public <T> void setThreadLocal(WorkflowThreadLocalInternal<T> key,
 T value)

Specified by:

setThreadLocal in interface WorkflowThread

getThreadLocal

public <T> Optional<Optional<T>> getThreadLocal(WorkflowThreadLocalInternal<T> key)

Retrieve data from thread locals. Returns 1. not found (an empty Optional) 2. found but null (an Optional of an empty Optional) 3. found and non-null (an Optional of an Optional of a value). The type nesting is because Java Optionals cannot understand "Some null" vs "None", which is exactly what we need here.

Specified by:

getThreadLocal in interface WorkflowThread

Type Parameters:

T -

Parameters:

key -

Returns:

one of three cases

getStackTrace

public String getStackTrace()

Specified by:

getStackTrace in interface WorkflowThread

Returns:

stack trace of the coroutine thread