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

إنشاء

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

إيقاف التشغيل

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