TracePropagatingExecutorService

public final class TracePropagatingExecutorService
extends Object implements ExecutorService

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


Un servizio di esecuzione che inoltra le attività a un'implementazione sottostante propagando il contesto di tracciamento.

In questo modo è possibile utilizzare le funzionalità di tracciamento come CloseableTraceScope nelle attività inviate.

Riepilogo

Metodi pubblici

boolean awaitTermination(long timeout, TimeUnit unit)
static TracePropagatingExecutorService create(ExecutorService delegate)

Crea un ExecutorService che delega all'executor delegato specificato.

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)

Metodi protetti

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

Metodi pubblici

awaitTermination

public boolean awaitTermination (long timeout, 
                TimeUnit unit)

Parametri
timeout long

unit TimeUnit

Resi
boolean

Genera
InterruptedException

create

public static TracePropagatingExecutorService create (ExecutorService delegate)

Crea un ExecutorService che delega all'executor delegato specificato.

Tieni presente che la traccia attiva propagata alle attività è quella attiva nelle chiamate al metodo dell'executor. Questa operazione viene eseguita perché TF costruisce la maggior parte degli oggetti prima di avviare l'invocazione e allegare la traccia.

Parametri
delegate ExecutorService

Resi
TracePropagatingExecutorService

execute

public void execute (Runnable command)

Parametri
command Runnable

invokeAll

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

Parametri
tasks Collection

Resi
List<Future<T>>

Genera
InterruptedException

invokeAll

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

Parametri
tasks Collection

timeout long

unit TimeUnit

Resi
List<Future<T>>

Genera
InterruptedException

invokeAny

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

Parametri
tasks Collection

Resi
T

Genera
ExecutionException
InterruptedException

invokeAny

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

Parametri
tasks Collection

timeout long

unit TimeUnit

Resi
T

Genera
ExecutionException
InterruptedException
TimeoutException

isShutdown

public boolean isShutdown ()

Resi
boolean

isTerminated

public boolean isTerminated ()

Resi
boolean

shutdown

public void shutdown ()

shutdownNow

public List<Runnable> shutdownNow ()

Resi
List<Runnable>

invia

public Future<?> submit (Runnable task)

Parametri
task Runnable

Resi
Future<?>

invia

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

Parametri
task Callable

Resi
Future<T>

invia

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

Parametri
task Runnable

result T

Resi
Future<T>

Metodi protetti

wrapTasks

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

Parametri
tasks Collection

Risultati
Collection<? extends Callable<T>>