TracePropagatingExecutorService

public final class TracePropagatingExecutorService
extends Object implements ExecutorService

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

Ein Executor-Dienst, der Aufgaben an eine zugrunde liegende Implementierung weiterleitet und gleichzeitig den Tracing-Kontext weitergibt.

So können in eingereichten Aufgaben Tracing-Funktionen wie CloseableTraceScope verwendet werden.

Zusammenfassung

Öffentliche Methoden

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

Erstellt einen ExecutorService, der an den angegebenen Delegat-Executor delegiert.

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)

Geschützte Methoden

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

Öffentliche Methoden

awaitTermination

public boolean awaitTermination (long timeout, 
                TimeUnit unit)

Parameter
timeout long

unit TimeUnit

Gibt Folgendes zurück:
boolean

Löst aus
InterruptedException

create

public static TracePropagatingExecutorService create (ExecutorService delegate)

Erstellt einen ExecutorService, der an den angegebenen Delegat-Executor delegiert.

Der aktive Trace, der an Aufgaben weitergegeben wird, ist der, der bei Aufrufen der Executor-Methode aktiv ist. Das liegt daran, dass TF die meisten Objekte erstellt, bevor der Aufruf gestartet und der Trace angehängt wird.

Parameter
delegate ExecutorService

Gibt Folgendes zurück:
TracePropagatingExecutorService

execute

public void execute (Runnable command)

Parameter
command Runnable

invokeAll

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

Parameter
tasks Collection

Gibt Folgendes zurück:
List<Future<T>>

Löst aus
InterruptedException

invokeAll

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

Parameter
tasks Collection

timeout long

unit TimeUnit

Gibt Folgendes zurück:
List<Future<T>>

Löst aus
InterruptedException

invokeAny

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

Parameter
tasks Collection

Gibt Folgendes zurück:
T

Löst aus
ExecutionException
InterruptedException

invokeAny

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

Parameter
tasks Collection

timeout long

unit TimeUnit

Gibt Folgendes zurück:
T

Löst aus
ExecutionException
InterruptedException
TimeoutException

isShutdown

public boolean isShutdown ()

Gibt Folgendes zurück:
boolean

isTerminated

public boolean isTerminated ()

Gibt Folgendes zurück:
boolean

shutdown

public void shutdown ()

shutdownNow

public List<Runnable> shutdownNow ()

Gibt Folgendes zurück:
List<Runnable>

Senden

public Future<?> submit (Runnable task)

Parameter
task Runnable

Gibt Folgendes zurück:
Future<?>

Senden

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

Parameter
task Callable

Gibt Folgendes zurück:
Future<T>

Senden

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

Parameter
task Runnable

result T

Gibt Folgendes zurück:
Future<T>

Geschützte Methoden

wrapTasks

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

Parameter
tasks Collection

Gibt zurück
Collection<? extends Callable<T>>