TracePropagatingExecutorService

public final class TracePropagatingExecutorService
extends Object implements ExecutorService

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


Usługa wykonawcza, która przekazuje zadania do podstawowej implementacji, propagując kontekst śledzenia.

Umożliwia to korzystanie z narzędzi śledzenia, takich jak CloseableTraceScope, w przesłanych zadaniach.

Podsumowanie

Metody publiczne

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

Tworzy obiekt ExecutorService, który deleguje zadania do danego wykonawcy delegowania.

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)

Metody chronione

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

Metody publiczne

awaitTermination

public boolean awaitTermination (long timeout, 
                TimeUnit unit)

Parametry
timeout long

unit TimeUnit

Zwraca
boolean

Zgłasza
InterruptedException

utwórz

public static TracePropagatingExecutorService create (ExecutorService delegate)

Tworzy obiekt ExecutorService, który deleguje zadania do podanego wykonawcy delegowania.

Pamiętaj, że aktywny ślad, który jest propagowany do zadań, to ten, który jest aktywny w wywołaniach metody wykonawcy. Dzieje się tak, ponieważ TF tworzy większość obiektów przed rozpoczęciem wywołania i dołączeniem śladu.

Parametry
delegate ExecutorService

Zwraca
TracePropagatingExecutorService

wykonać, przeprowadzić, uruchomić

public void execute (Runnable command)

Parametry
command Runnable

invokeAll

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

Parametry
tasks Collection

Zwraca
List<Future<T>>

Zgłasza
InterruptedException

invokeAll

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

Parametry
tasks Collection

timeout long

unit TimeUnit

Zwraca
List<Future<T>>

Zgłasza
InterruptedException

invokeAny

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

Parametry
tasks Collection

Zwraca
T

Zgłasza
ExecutionException
InterruptedException

invokeAny

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

Parametry
tasks Collection

timeout long

unit TimeUnit

Zwraca
T

Zgłasza
ExecutionException
InterruptedException
TimeoutException

isShutdown

public boolean isShutdown ()

Zwraca
boolean

isTerminated

public boolean isTerminated ()

Zwraca
boolean

wyłączenie,

public void shutdown ()

shutdownNow

public List<Runnable> shutdownNow ()

Zwraca
List<Runnable>

prześlij

public Future<?> submit (Runnable task)

Parametry
task Runnable

Zwraca
Future<?>

prześlij

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

Parametry
task Callable

Zwraca
Future<T>

prześlij

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

Parametry
task Runnable

result T

Zwraca
Future<T>

Metody chronione

wrapTasks

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

Parametry
tasks Collection

Zwraca
Collection<? extends Callable<T>>