Package de.dytanic.cloudnet.common.concurrent

Class ListenableTask<V>

java.lang.Object

de.dytanic.cloudnet.common.concurrent.ListenableTask<V>

All Implemented Interfaces:

ITask<V>, java.util.concurrent.Callable<V>, java.util.concurrent.Future<V>

@NotNull
public class ListenableTask<V>
extends java.lang.Object
implements ITask<V>

Constructor Summary

Constructors

Constructor	Description
ListenableTask(java.util.concurrent.Callable<V> callable)
ListenableTask(java.util.concurrent.Callable<V> callable, ITaskListener<V> listener)

Method Summary

Modifier and Type	Method	Description
@NotNull ITask<V>	addListener(ITaskListener<V> listener)
V	call()
boolean	cancel(boolean mayInterruptIfRunning)
@NotNull ITask<V>	clearListeners()
V	get()
V	get(long timeout, @NotNull java.util.concurrent.TimeUnit unit)
V	get(long time, java.util.concurrent.TimeUnit timeUnit, V def)
java.util.concurrent.Callable<V>	getCallable()
V	getDef(V def)
java.util.Collection<ITaskListener<V>>	getListeners()
V	getValue()
boolean	isCancelled()
boolean	isDone()
<T> ListenableTask<T>	mapThrowable(ThrowableFunction<V,T,java.lang.Throwable> function)

Methods inherited from class java.lang.Object

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

Methods inherited from interface de.dytanic.cloudnet.common.concurrent.ITask

addListener, fireExceptionOnFailure, map, onCancelled, onComplete, onComplete, onFailure, onFailure

Constructor Detail

ListenableTask

public ListenableTask(java.util.concurrent.Callable<V> callable)

ListenableTask

public ListenableTask(java.util.concurrent.Callable<V> callable,
                      ITaskListener<V> listener)

Method Detail

getCallable

public java.util.concurrent.Callable<V> getCallable()

Specified by:

getCallable in interface ITask<V>

getListeners

public java.util.Collection<ITaskListener<V>> getListeners()

Specified by:

getListeners in interface ITask<V>

getValue

public V getValue()

isDone

public boolean isDone()

Specified by:

isDone in interface java.util.concurrent.Future<V>

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface java.util.concurrent.Future<V>

addListener

@NotNull
public @NotNull ITask<V> addListener(ITaskListener<V> listener)

Specified by:

addListener in interface ITask<V>

clearListeners

@NotNull
public @NotNull ITask<V> clearListeners()

Specified by:

clearListeners in interface ITask<V>

getDef

public V getDef(V def)

Specified by:

getDef in interface ITask<V>

get

public V get(long time,
             java.util.concurrent.TimeUnit timeUnit,
             V def)

Specified by:

get in interface ITask<V>

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface java.util.concurrent.Future<V>

get

public V get()
      throws java.lang.InterruptedException

Specified by:

get in interface java.util.concurrent.Future<V>

Throws:

java.lang.InterruptedException

get

public V get(long timeout,
             @NotNull
             @NotNull java.util.concurrent.TimeUnit unit)
      throws java.lang.InterruptedException,
             java.util.concurrent.TimeoutException

Specified by:

get in interface java.util.concurrent.Future<V>

Throws:

java.lang.InterruptedException

java.util.concurrent.TimeoutException

call

public V call()

Specified by:

call in interface java.util.concurrent.Callable<V>

mapThrowable

public <T> ListenableTask<T> mapThrowable(ThrowableFunction<V,T,java.lang.Throwable> function)

Specified by:

mapThrowable in interface ITask<V>