com.hazelcast.internal.util

Class SimpleCompletableFuture<T>

java.lang.Object

com.hazelcast.spi.impl.AbstractCompletableFuture<T>

com.hazelcast.internal.util.SimpleCompletableFuture<T>

All Implemented Interfaces:

ICompletableFuture<T>, InternalCompletableFuture<T>, Future<T>

public class SimpleCompletableFuture<T>
extends AbstractCompletableFuture<T>
implements InternalCompletableFuture<T>

Generic implementation of InternalCompletableFuture. Requires only NodeEngine.

Constructor Summary

Constructors

Constructor and Description
SimpleCompletableFuture(NodeEngine nodeEngine)

Method Summary

Modifier and Type	Method and Description
boolean	complete(Object value) Completes this future.
T	join() Waits for this future to complete.
boolean	setResult(Object result) Sets the result.

Methods inherited from class com.hazelcast.spi.impl.AbstractCompletableFuture

andThen, andThen, cancel, cancelled, done, get, get, getResult, isCancelled, isDone, shouldCancel

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.core.ICompletableFuture

andThen, andThen

Methods inherited from interface java.util.concurrent.Future

cancel, get, get, isCancelled, isDone

Constructor Detail

SimpleCompletableFuture

public SimpleCompletableFuture(NodeEngine nodeEngine)

Method Detail

setResult

public boolean setResult(Object result)

Description copied from class: AbstractCompletableFuture

Sets the result. If result is an instance of Throwable, this future will be completed exceptionally. That is, AbstractCompletableFuture.get() will throw the exception rather than return it.

Overrides:

setResult in class AbstractCompletableFuture<T>

Returns:

true, if this call made this future to complete

join

public T join()

Description copied from interface: InternalCompletableFuture

Waits for this future to complete.

Specified by:

join in interface InternalCompletableFuture<T>

Returns:

the result.

complete

public boolean complete(Object value)

Description copied from interface: InternalCompletableFuture

Completes this future.

Specified by:

complete in interface InternalCompletableFuture<T>

Parameters:

value - the value to complete this future with.

Returns:

true if this invocation caused this InternalCompletableFuture to complete, else false