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)

パブリック メソッド

awaitTermination

public boolean awaitTermination (long timeout, 
                TimeUnit unit)

パラメータ
timeout	long
unit	TimeUnit

戻り値
boolean

例外
InterruptedException

create

public static TracePropagatingExecutorService create (ExecutorService delegate)

指定されたデリゲート エグゼキュータに委任する ExecutorService を作成します。

タスクに伝播されるアクティブなトレースは、エグゼキュータ メソッドの呼び出しでアクティブなトレースです。これは、TF が呼び出しを開始してトレースをアタッチする前に、ほとんどのオブジェクトを構築するためです。

パラメータ
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

isTerminated

public boolean isTerminated ()

戻り値
boolean

shutdown

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>>