程序包 com.alibaba.dubbo.common.concurrent

类 ListenableFutureTask<V>

java.lang.Object

java.util.concurrent.FutureTask<V>

com.alibaba.dubbo.common.concurrent.ListenableFutureTask<V>

所有已实现的接口:

ListenableFuture<V>, Runnable, Future<V>, RunnableFuture<V>

public class ListenableFutureTask<V>
extends FutureTask<V>
implements ListenableFuture<V>

A FutureTask that also implements the ListenableFuture interface. Unlike FutureTask, ListenableFutureTask does not provide an overrideable done() method. For similar functionality, call addListener(java.lang.Runnable, java.util.concurrent.Executor).

方法概要

修饰符和类型	方法	说明
void	addListener(Runnable listener)
void	addListener(Runnable listener, Executor exec)	Registers a listener to be run on the given executor.
static <V> ListenableFutureTask<V>	create(Runnable runnable, V result)	Creates a ListenableFutureTask that will upon running, execute the given Runnable, and arrange that get will return the given result on successful completion.
static <V> ListenableFutureTask<V>	create(Callable<V> callable)	Creates a ListenableFutureTask that will upon running, execute the given Callable.

从类继承的方法 java.util.concurrent.FutureTask

cancel, get, get, isCancelled, isDone, run, toString

从类继承的方法 java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

从接口继承的方法 java.util.concurrent.Future

cancel, get, get, isCancelled, isDone

方法详细资料

create

public static <V> ListenableFutureTask<V> create(Callable<V> callable)

Creates a ListenableFutureTask that will upon running, execute the given Callable.

参数:

callable - the callable task

从以下版本开始:

10.0

create

public static <V> ListenableFutureTask<V> create(Runnable runnable,
                                                 V result)

Creates a ListenableFutureTask that will upon running, execute the given Runnable, and arrange that get will return the given result on successful completion.

参数:

runnable - the runnable task

result - the result to return on successful completion. If you don't need a particular result, consider using constructions of the form: ListenableFuture<?> f = ListenableFutureTask.create(runnable, null)

从以下版本开始:

10.0

addListener

public void addListener(Runnable listener,
                        Executor exec)

从接口复制的说明: ListenableFuture

Registers a listener to be run on the given executor. The listener will run when the Future's computation is complete or, if the computation is already complete, immediately.

There is no guaranteed ordering of execution of listeners, but any listener added through this method is guaranteed to be called once the computation is complete.

Exceptions thrown by a listener will be propagated up to the executor. Any exception thrown during Executor.execute (e.g., a RejectedExecutionException or an exception thrown by inline execution) will be caught and logged.

Note: For fast, lightweight listeners that would be safe to execute in any thread, consider MoreExecutors#sameThreadExecutor. For heavier listeners, sameThreadExecutor() carries some caveats. For example, the listener may run on an unpredictable or undesirable thread:

• If this Future is done at the time addListener is called, addListener will execute the listener inline.
• If this Future is not yet done, addListener will schedule the listener to be run by the thread that completes this Future, which may be an internal system thread such as an RPC network thread.

Also note that, regardless of which thread executes the sameThreadExecutor() listener, all other registered but unexecuted listeners are prevented from running during its execution, even if those listeners are to run in other executors.

This is the most general listener interface. For common operations performed using listeners, see Futures. For a simplified but general listener interface, see addCallback().

指定者:

addListener 在接口中 ListenableFuture<V>

参数:

listener - the listener to run when the computation is complete

exec - the executor to run the listener in

addListener

public void addListener(Runnable listener)

指定者:

addListener 在接口中 ListenableFuture<V>