TracePropagatingExecutorService

public final class TracePropagatingExecutorService
extends Object implements ExecutorService

java.lang.Object
   ↳ com.android.tradefed.invoker.tracing.TracePropagatingExecutorService


Um serviço de executor que encaminha tarefas para uma implementação subjacente enquanto propaga o contexto de rastreamento.

Isso permite usar 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 ExecutorService que delega ao executor de delegação especificado.

void execute(Runnable command)
<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
<T> T invokeAny(Collection<? extends Callable<T>> tasks)
<T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
boolean isShutdown()
boolean isTerminated()
void shutdown()
List<Runnable> shutdownNow()
Future<?> submit(Runnable task)
<T> Future<T> submit(Callable<T> task)
<T> Future<T> submit(Runnable task, T result)

Métodos protegidos

<T> Collection<? extends Callable<T>> wrapTasks(Collection<? extends Callable<T>> tasks)

Métodos públicos

awaitTermination

public boolean awaitTermination (long timeout, 
                TimeUnit unit)

Parâmetros
timeout long

unit TimeUnit

Retorna
boolean

Gera
InterruptedException

create

public static TracePropagatingExecutorService create (ExecutorService delegate)

Cria um ExecutorService que delega ao executor de delegação especificado.

Aquele que é propagado para as tarefas é o rastreamento ativo nas chamadas para o método do executor. Isso é feito porque o TF cria a maioria dos objetos antes de iniciar a invocação e anexar o rastreamento.

Parâmetros
delegate ExecutorService

Retorna
TracePropagatingExecutorService

execute

public void execute (Runnable command)

Parâmetros
command Runnable

invokeAll

public List<Future<T>> invokeAll (Collection<? extends Callable<T>> tasks)

Parâmetros
tasks Collection

Retorna
List<Future<T>>

Gera
InterruptedException

invokeAll

public List<Future<T>> invokeAll (Collection<? extends Callable<T>> tasks, 
                long timeout, 
                TimeUnit unit)

Parâmetros
tasks Collection

timeout long

unit TimeUnit

Retorna
List<Future<T>>

Gera
InterruptedException

invokeAny

public T invokeAny (Collection<? extends Callable<T>> tasks)

Parâmetros
tasks Collection

Retorna
T

Gera
ExecutionException
InterruptedException

invokeAny

public T invokeAny (Collection<? extends Callable<T>> tasks, 
                long timeout, 
                TimeUnit unit)

Parâmetros
tasks Collection

timeout long

unit TimeUnit

Retorna
T

Gera
ExecutionException
InterruptedException
TimeoutException

isShutdown

public boolean isShutdown ()

Retorna
boolean

isTerminated

public boolean isTerminated ()

Retorna
boolean

shutdown

public void shutdown ()

shutdownNow

public List<Runnable> shutdownNow ()

Retorna
List<Runnable>

enviar

public Future<?> submit (Runnable task)

Parâmetros
task Runnable

Retorna
Future<?>

enviar

public Future<T> submit (Callable<T> task)

Parâmetros
task Callable

Retorna
Future<T>

enviar

public Future<T> submit (Runnable task, 
                T result)

Parâmetros
task Runnable

result T

Retorna
Future<T>

Métodos protegidos

wrapTasks

protected Collection<? extends Callable<T>> wrapTasks (Collection<? extends Callable<T>> tasks)

Parâmetros
tasks Collection

Retorna
Collection<? extends Callable<T>>