Package software.amazon.lambda.durable.operation

Class WaitOperation

java.lang.Object

software.amazon.lambda.durable.operation.BaseDurableOperation<Void>

software.amazon.lambda.durable.operation.WaitOperation

All Implemented Interfaces:

DurableFuture<Void>

public class WaitOperation
extends BaseDurableOperation<Void>

Field Summary

Fields inherited from class software.amazon.lambda.durable.operation.BaseDurableOperation

completionFuture

Constructor Summary

Constructors

Constructor	Description
WaitOperation(String operationId, String name, Duration duration, ExecutionManager executionManager)	Convenience constructor for root-context operations where parentId is null.
WaitOperation(String operationId, String name, Duration duration, ExecutionManager executionManager, String parentId)

Method Summary

Modifier and Type	Method	Description
void	execute()	Starts the operation.
Void	get()	Blocks until the operation completes and returns the result.

Methods inherited from class software.amazon.lambda.durable.operation.BaseDurableOperation

deregisterActiveThread, deserializeException, deserializeResult, getCurrentThreadContext, getName, getOperation, getOperationId, getParentId, getType, isOperationCompleted, markAlreadyCompleted, onCheckpointComplete, pollForOperationUpdates, pollForOperationUpdates, registerActiveThread, sendOperationUpdate, sendOperationUpdateAsync, serializeException, serializeResult, setCurrentThreadContext, terminateExecution, terminateExecutionWithIllegalDurableOperationException, validateReplay, waitForOperationCompletion

Methods inherited from class java.lang.Object

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

Constructor Details

WaitOperation

public WaitOperation(String operationId,
 String name,
 Duration duration,
 ExecutionManager executionManager,
 String parentId)

WaitOperation

public WaitOperation(String operationId,
 String name,
 Duration duration,
 ExecutionManager executionManager)

Convenience constructor for root-context operations where parentId is null.

Method Details

execute

public void execute()

Description copied from class: BaseDurableOperation

Starts the operation. Returns immediately after starting background work or checkpointing. Does not block.

Specified by:

execute in class BaseDurableOperation<Void>

get

public Void get()

Description copied from interface: DurableFuture

Blocks until the operation completes and returns the result.

This delegates to operation.get() which handles: - Thread deregistration (allows suspension) - Thread reactivation (resumes execution) - Result retrieval

Returns:

the operation result