类 ListenableFutureTask<V>
-
- <V>
-
- com.alibaba.dubbo.common.concurrent.ListenableFutureTask<V>
-
- 所有已实现的接口:
,
<V>
,<V>
public class ListenableFutureTask<V> extends <V> implements ListenableFuture<V>
A that also implements theListenableFuture
interface. UnlikeFutureTask
,ListenableFutureTask
does not provide an overrideable method. For similar functionality, calladdListener(java.lang.Runnable, java.util.concurrent.Executor)
.
-
-
方法概要
所有方法 静态方法 实例方法 具体方法 修饰符和类型 方法 说明 void
listener)
void
listener, exec)
Registers a listener to be on the given executor.static <V> ListenableFutureTask<V>
runnable, V result)
Creates aListenableFutureTask
that will upon running, execute the givenRunnable
, and arrange thatget
will return the given result on successful completion.static <V> ListenableFutureTask<V>
<V> callable)
Creates aListenableFutureTask
that will upon running, execute the givenCallable
.
-
-
-
方法详细资料
-
create
public static <V> <V> callable)
Creates aListenableFutureTask
that will upon running, execute the givenCallable
.- 参数:
callable
- the callable task- 从以下版本开始:
- 10.0
-
create
public static <V> runnable, V result)
Creates aListenableFutureTask
that will upon running, execute the givenRunnable
, and arrange thatget
will return the given result on successful completion.- 参数:
runnable
- the runnable taskresult
- 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( listener, exec)
从接口复制的说明:ListenableFuture
Registers a listener to be on the given executor. The listener will run when theFuture
's computation is 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., aRejectedExecutionException
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 timeaddListener
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 thisFuture
, 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, seeaddCallback()
.- 指定者:
addListener
在接口中ListenableFuture<V>
- 参数:
listener
- the listener to run when the computation is completeexec
- the executor to run the listener in
- If this
-
addListener
public void addListener( listener)
- 指定者:
addListener
在接口中ListenableFuture<V>
-
-