Package com.ticxo.modelengine.api.utils.promise

Class AbstractPromise<T>

java.lang.Object

com.ticxo.modelengine.api.utils.promise.AbstractPromise<T>

All Implemented Interfaces:

Promise<T>, Future<T>

Direct Known Subclasses:

AbstractFoliaPromise, LegacyPromise

public abstract class AbstractPromise<T>
extends Object
implements Promise<T>

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractPromise()
protected	AbstractPromise(T val)

Method Summary

Modifier and Type	Method	Description
boolean	cancel(boolean mayInterruptIfRunning)
protected abstract <U> AbstractPromise<U>	createEmpty()
protected abstract void	executeAsync(Runnable runnable)
protected abstract void	executeAsync(Runnable runnable, int delay)
protected abstract void	executeSync(Runnable runnable)
protected abstract void	executeSync(Runnable runnable, int delay)
T	get()
T	get(long timeout, TimeUnit unit)
boolean	isCancelled()
boolean	isDone()
Promise<T>	runAsync(Runnable runnable)
Promise<T>	runAsyncDelay(Runnable runnable, int delay)
Promise<T>	runSync(Runnable runnable)
Promise<T>	runSyncDelay(Runnable runnable, int delay)
Promise<T>	supplyAsync(Supplier<T> supplier)
Promise<T>	supplyAsyncDelay(Supplier<T> supplier, int delay)
Promise<T>	supplySync(Supplier<T> supplier)
Promise<T>	supplySyncDelay(Supplier<T> supplier, int delay)
<U> Promise<U>	thenApplyAsync(Function<? super T,? extends U> function)
<U> Promise<U>	thenApplyAsyncDelay(Function<? super T,? extends U> function, int delay)
<U> Promise<U>	thenApplySync(Function<? super T,? extends U> function)
<U> Promise<U>	thenApplySyncDelay(Function<? super T,? extends U> function, int delay)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.ticxo.modelengine.api.utils.promise.Promise

thenAcceptAsync, thenAcceptAsyncDelay, thenAcceptSync, thenAcceptSyncDelay, thenRunAsync, thenRunAsyncDelay, thenRunSync, thenRunSyncDelay

Constructor Details

AbstractPromise

protected AbstractPromise()

AbstractPromise

protected AbstractPromise(T val)

Method Details

runSync

public Promise<T> runSync(Runnable runnable)

Specified by:

runSync in interface Promise<T>

runSyncDelay

public Promise<T> runSyncDelay(Runnable runnable,
 int delay)

Specified by:

runSyncDelay in interface Promise<T>

runAsync

public Promise<T> runAsync(Runnable runnable)

Specified by:

runAsync in interface Promise<T>

runAsyncDelay

public Promise<T> runAsyncDelay(Runnable runnable,
 int delay)

Specified by:

runAsyncDelay in interface Promise<T>

supplySync

public Promise<T> supplySync(Supplier<T> supplier)

Specified by:

supplySync in interface Promise<T>

supplySyncDelay

public Promise<T> supplySyncDelay(Supplier<T> supplier,
 int delay)

Specified by:

supplySyncDelay in interface Promise<T>

supplyAsync

public Promise<T> supplyAsync(Supplier<T> supplier)

Specified by:

supplyAsync in interface Promise<T>

supplyAsyncDelay

public Promise<T> supplyAsyncDelay(Supplier<T> supplier,
 int delay)

Specified by:

supplyAsyncDelay in interface Promise<T>

thenApplySync

public <U> Promise<U> thenApplySync(Function<? super T,? extends U> function)

Specified by:

thenApplySync in interface Promise<T>

thenApplySyncDelay

public <U> Promise<U> thenApplySyncDelay(Function<? super T,? extends U> function,
 int delay)

Specified by:

thenApplySyncDelay in interface Promise<T>

thenApplyAsync

public <U> Promise<U> thenApplyAsync(Function<? super T,? extends U> function)

Specified by:

thenApplyAsync in interface Promise<T>

thenApplyAsyncDelay

public <U> Promise<U> thenApplyAsyncDelay(Function<? super T,? extends U> function,
 int delay)

Specified by:

thenApplyAsyncDelay in interface Promise<T>

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<T>

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future<T>

isDone

public boolean isDone()

Specified by:

isDone in interface Future<T>

get

public T get()
      throws InterruptedException,
ExecutionException

Specified by:

get in interface Future<T>

Throws:

InterruptedException

ExecutionException

get

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

Specified by:

get in interface Future<T>

Throws:

InterruptedException

ExecutionException

TimeoutException

createEmpty

protected abstract <U> AbstractPromise<U> createEmpty()

executeSync

protected abstract void executeSync(Runnable runnable)

executeSync

protected abstract void executeSync(Runnable runnable,
 int delay)

executeAsync

protected abstract void executeAsync(Runnable runnable)

executeAsync

protected abstract void executeAsync(Runnable runnable,
 int delay)