org.infinispan.util.concurrent

Class ConditionFuture<T>

java.lang.Object

org.infinispan.util.concurrent.ConditionFuture<T>

public class ConditionFuture<T>
extends Object

A mixture between a CompletableFuture and a Condition.

Since:

10.1

Author:

Dan Berindei

Constructor Summary

Constructors

Constructor and Description
ConditionFuture(ScheduledExecutorService timeoutExecutor)

Method Summary

Modifier and Type	Method and Description
CompletionStage<Void>	newConditionStage(Predicate<T> test, long timeout, TimeUnit timeUnit) Create a new CompletionStage that completes after the first update(Object) call with a value satisfying the test predicate.
void	stop()
void	update(T value) Update the value and complete any outstanding condition stages for which the value satisfies the predicate.
void	updateAsync(T value, Executor executor) Update the value and complete any outstanding condition stages for which the value satisfies the predicate.

Methods inherited from class java.lang.Object

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

Constructor Detail

ConditionFuture

public ConditionFuture(ScheduledExecutorService timeoutExecutor)

Method Detail

newConditionStage

public CompletionStage<Void> newConditionStage(Predicate<T> test,
                                               long timeout,
                                               TimeUnit timeUnit)

Create a new CompletionStage that completes after the first update(Object) call with a value satisfying the test predicate.

Parameters:

test - The predicate.

timeout - Maximum time to wait for a value satisfying the predicate.

timeUnit - Timeout time unit.

update

public void update(T value)

Update the value and complete any outstanding condition stages for which the value satisfies the predicate.

updateAsync

public void updateAsync(T value,
                        Executor executor)

Update the value and complete any outstanding condition stages for which the value satisfies the predicate.

stop

public void stop()