io.zeebe.util.sched.future

Class CompletableActorFuture<V>

java.lang.Object

io.zeebe.util.sched.future.CompletableActorFuture<V>

All Implemented Interfaces:

ActorFuture<V>, Future<V>

public class CompletableActorFuture<V>
extends Object
implements ActorFuture<V>

Completable future implementation that is garbage free and reusable

Field Summary

Fields

Modifier and Type	Field and Description
protected String	failure
protected Throwable	failureCause
protected V	value

Constructor Summary

Constructors

Constructor and Description
CompletableActorFuture()

Method Summary

Modifier and Type	Method and Description
void	block(ActorTask onCompletion) To be used by scheduler only
boolean	cancel(boolean mayInterruptIfRunning)
boolean	close() future is reusable after close
void	complete(V value)
static <V> CompletableActorFuture<V>	completed(V result)
static <V> CompletableActorFuture<V>	completedExceptionally(Throwable throwable)
void	completeExceptionally(String failure, Throwable throwable)
void	completeExceptionally(Throwable throwable)
void	completeWith(CompletableActorFuture<V> otherFuture)
V	get()
V	get(long timeout, TimeUnit unit)
Throwable	getException()
boolean	isAwaitingResult()
boolean	isCancelled()
boolean	isClosed()
boolean	isCompletedExceptionally()
boolean	isDone()
V	join()
void	setAwaitingResult()
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

value

protected V value

failure

protected String failure

failureCause

protected Throwable failureCause

Constructor Detail

CompletableActorFuture

public CompletableActorFuture()

Method Detail

setAwaitingResult

public void setAwaitingResult()

completed

public static <V> CompletableActorFuture<V> completed(V result)

completedExceptionally

public static <V> CompletableActorFuture<V> completedExceptionally(Throwable throwable)

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<V>

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future<V>

isDone

public boolean isDone()

Specified by:

isDone in interface Future<V>

isCompletedExceptionally

public boolean isCompletedExceptionally()

Specified by:

isCompletedExceptionally in interface ActorFuture<V>

isAwaitingResult

public boolean isAwaitingResult()

block

public void block(ActorTask onCompletion)

Description copied from interface: ActorFuture

To be used by scheduler only

Specified by:

block in interface ActorFuture<V>

get

public V get()
      throws ExecutionException,
             InterruptedException

Specified by:

get in interface Future<V>

Throws:

ExecutionException

InterruptedException

get

public V get(long timeout,
             TimeUnit unit)
      throws ExecutionException,
             TimeoutException,
             InterruptedException

Specified by:

get in interface Future<V>

Throws:

ExecutionException

TimeoutException

InterruptedException

complete

public void complete(V value)

Specified by:

complete in interface ActorFuture<V>

completeExceptionally

public void completeExceptionally(String failure,
                                  Throwable throwable)

Specified by:

completeExceptionally in interface ActorFuture<V>

completeExceptionally

public void completeExceptionally(Throwable throwable)

Specified by:

completeExceptionally in interface ActorFuture<V>

join

public V join()

Specified by:

join in interface ActorFuture<V>

close

public boolean close()

future is reusable after close

isClosed

public boolean isClosed()

getException

public Throwable getException()

Specified by:

getException in interface ActorFuture<V>

completeWith

public void completeWith(CompletableActorFuture<V> otherFuture)

toString

public String toString()

Overrides:

toString in class Object