TracePropagatingExecutorService

public final class TracePropagatingExecutorService
extends Object implements ExecutorService

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


Layanan eksekutor yang meneruskan tugas ke penerapan yang mendasarinya sambil menyebarkan konteks pelacakan.

Hal ini memungkinkan penggunaan fasilitas pelacakan seperti CloseableTraceScope dalam tugas yang dikirimkan.

Ringkasan

Metode publik

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

Membuat ExecutorService yang mendelegasikan ke eksekutor delegasi yang diberikan.

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)

Metode yang dilindungi

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

Metode publik

awaitTermination

public boolean awaitTermination (long timeout, 
                TimeUnit unit)

Parameter
timeout long

unit TimeUnit

Hasil
boolean

Menampilkan
InterruptedException

buat

public static TracePropagatingExecutorService create (ExecutorService delegate)

Membuat ExecutorService yang mendelegasikan ke eksekutor delegasi yang diberikan.

Perhatikan bahwa rekaman aktivitas aktif yang diteruskan ke tugas adalah rekaman aktivitas yang aktif pada panggilan ke metode executor. Hal ini dilakukan karena TF membuat sebagian besar objek sebelum memulai pemanggilan dan melampirkan rekaman aktivitas.

Parameter
delegate ExecutorService

Hasil
TracePropagatingExecutorService

execute

public void execute (Runnable command)

Parameter
command Runnable

invokeAll

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

Parameter
tasks Collection

Hasil
List<Future<T>>

Menampilkan
InterruptedException

invokeAll

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

Parameter
tasks Collection

timeout long

unit TimeUnit

Hasil
List<Future<T>>

Menampilkan
InterruptedException

invokeAny

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

Parameter
tasks Collection

Hasil
T

Menampilkan
ExecutionException
InterruptedException

invokeAny

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

Parameter
tasks Collection

timeout long

unit TimeUnit

Hasil
T

Menampilkan
ExecutionException
InterruptedException
TimeoutException

isShutdown

public boolean isShutdown ()

Hasil
boolean

isTerminated

public boolean isTerminated ()

Hasil
boolean

shutdown

public void shutdown ()

shutdownNow

public List<Runnable> shutdownNow ()

Hasil
List<Runnable>

kirim

public Future<?> submit (Runnable task)

Parameter
task Runnable

Hasil
Future<?>

kirim

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

Parameter
task Callable

Hasil
Future<T>

kirim

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

Parameter
task Runnable

result T

Hasil
Future<T>

Metode yang dilindungi

wrapTasks

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

Parameter
tasks Collection

Hasil
Collection<? extends Callable<T>>