TracePropagatingExecutorService
public final class TracePropagatingExecutorService
extends Object
java.lang.Object |
↳ | com.android.tradefed.invoker.tracing.TracePropagatingExecutorService |
Um serviço executor que encaminha tarefas para uma implementação subjacente enquanto propaga o contexto de rastreamento.
Isso permite o uso de recursos de rastreamento, como CloseableTraceScope
, em tarefas enviadas.
Resumo
Métodos públicos |
---|
boolean | awaitTermination (long timeout, TimeUnit unit) |
static TracePropagatingExecutorService | create (ExecutorService delegate) Cria um ERROR(/ExecutorService) que delega para o executor delegado especificado. |
void | execute (Runnable command) |
<T> | invokeAll ( tasks, long timeout, TimeUnit unit) invokeAll ( tasks, long timeout, TimeUnit unit) |
<T> | invokeAll ( tasks) invokeAll ( tasks) |
<T> T | invokeAny ( tasks) invokeAny ( tasks) |
<T> T | invokeAny ( tasks, long timeout, TimeUnit unit) invokeAny ( tasks, long timeout, TimeUnit unit) |
boolean | isShutdown () |
boolean | isTerminated () |
void | shutdown () |
| shutdownNow () |
| submit (Runnable task) |
<T> | submit (Runnable task, T result) |
<T> | submit ( task) submit ( task) |
Métodos públicos
awaitTermination
public boolean awaitTermination (long timeout,
TimeUnit unit)
Parâmetros |
---|
timeout | long |
unit | TimeUnit |
criar
public static TracePropagatingExecutorService create (ExecutorService delegate)
Cria um ERROR(/ExecutorService)
que delega para o executor delegado especificado.
Observe que o rastreamento ativo em que é propagado para tarefas é aquele ativo em chamadas para o método executor. Isso é feito porque o TF constrói a maioria dos objetos antes de iniciar a invocação e anexar o rastreamento.
Parâmetros |
---|
delegate | ExecutorService |
executar
public void execute (Runnable command)
Parâmetros |
---|
command | Runnable |
invocaTodos
public invokeAll ( tasks,
long timeout,
TimeUnit unit)
Parâmetros |
---|
tasks | |
timeout | long |
unit | TimeUnit |
invocaTodos
public invokeAll ( tasks)
invocaAny
public T invokeAny ( tasks)
invocaAny
public T invokeAny ( tasks,
long timeout,
TimeUnit unit)
Parâmetros |
---|
tasks | |
timeout | long |
unit | TimeUnit |
isShutdown
public boolean isShutdown ()
Está terminado
public boolean isTerminated ()
desligar
public void shutdown ()
desligar agora
public shutdownNow ()
enviar
public submit (Runnable task)
enviar
public submit (Runnable task,
T result)
Parâmetros |
---|
task | Runnable |
result | T |
enviar
public submit ( task)
Métodos protegidos
wrapTasks
protected wrapTasks ( tasks)