Package software.amazon.lambda.durable.examples.wait

Class ConcurrentWaitForConditionExample

java.lang.Object

software.amazon.lambda.durable.DurableHandler<ConcurrentWaitForConditionExample.Input,String>

software.amazon.lambda.durable.examples.wait.ConcurrentWaitForConditionExample

All Implemented Interfaces:

com.amazonaws.services.lambda.runtime.RequestStreamHandler

public class ConcurrentWaitForConditionExample
extends DurableHandler<ConcurrentWaitForConditionExample.Input,String>

Example demonstrating concurrent waitForCondition operations using map.

Runs many (totalOperations) waitForCondition operations concurrently (maxConcurrency). Each operation:

1. Uses attempt count as state (replay-safe).
2. Fails and retries until the attempt count reaches the given threshold, and then succeeds

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	ConcurrentWaitForConditionExample.Input

Constructor Summary

Constructors

Constructor	Description
ConcurrentWaitForConditionExample()

Method Summary

Modifier and Type	Method	Description
String	handleRequest(ConcurrentWaitForConditionExample.Input input, DurableContext context)	Handle the durable execution.

Methods inherited from class software.amazon.lambda.durable.DurableHandler

createConfiguration, getConfiguration, handleRequest

Methods inherited from class java.lang.Object

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

Constructor Details

ConcurrentWaitForConditionExample

public ConcurrentWaitForConditionExample()

Method Details

handleRequest

public String handleRequest(ConcurrentWaitForConditionExample.Input input,
 DurableContext context)

Description copied from class: DurableHandler

Handle the durable execution.

Specified by:

handleRequest in class DurableHandler<ConcurrentWaitForConditionExample.Input,String>

Parameters:

input - User input

context - Durable context for operations

Returns:

Result