TracePropagatingExecutorService

public final class TracePropagatingExecutorService
extends Object implements ExecutorService

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

Сервис-исполнитель, который перенаправляет задачи в нижележащую реализацию, одновременно передавая контекст трассировки.

Это позволяет использовать средства трассировки, такие как CloseableTraceScope в отправляемых задачах.

Краткое содержание

Общедоступные методы

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

Создает объект ExecutorService , который делегирует задачи указанному исполнителю-делегату.

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)

Защищенные методы

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

Общедоступные методы

ожидание завершения 

public boolean awaitTermination (long timeout, 
                TimeUnit unit)

Параметры
timeout long

unit TimeUnit

Возвраты
boolean

Броски
InterruptedException

создавать 

public static TracePropagatingExecutorService create (ExecutorService delegate)

Создает объект ExecutorService , который делегирует задачи указанному исполнителю-делегату.

Обратите внимание, что активная трассировка, передаваемая задачам, — это та, которая активна при вызовах метода исполнителя. Это делается потому, что TensorFlow создает большинство объектов до начала вызова и прикрепления трассировки.

Параметры
delegate ExecutorService

Возвраты
TracePropagatingExecutorService

выполнять 

public void execute (Runnable command)

Параметры
command Runnable

invokeAll 

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

Параметры
tasks Collection

Возвраты
List<Future<T>>

Броски
InterruptedException

invokeAll 

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

Параметры
tasks Collection

timeout long

unit TimeUnit

Возвраты
List<Future<T>>

Броски
InterruptedException

invokeAny 

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

Параметры
tasks Collection

Возвраты
T

Броски
ExecutionException
InterruptedException

invokeAny 

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

Параметры
tasks Collection

timeout long

unit TimeUnit

Возвраты
T

Броски
ExecutionException
InterruptedException
TimeoutException

isShutdown 

public boolean isShutdown ()

Возвраты
boolean

завершено 

public boolean isTerminated ()

Возвраты
boolean

неисправность 

public void shutdown ()

shutdownNow 

public List<Runnable> shutdownNow ()

Возвраты
List<Runnable>

представлять на рассмотрение 

public Future<?> submit (Runnable task)

Параметры
task Runnable

Возвраты
Future<?>

представлять на рассмотрение 

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

Параметры
task Callable

Возвраты
Future<T>

представлять на рассмотрение 

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

Параметры
task Runnable

result T

Возвраты
Future<T>

Защищенные методы

wrapTasks 

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

Параметры
tasks Collection

Возвраты
Collection<? extends Callable<T>>