TracePropagatingExecutorService

public final class TracePropagatingExecutorService
extends Object implements ExecutorService

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


İzleme bağlamını yayarken görevleri temel bir uygulamaya ileten bir yürütme hizmeti.

Bu sayede, gönderilen görevlerde CloseableTraceScope gibi izleme olanakları kullanılabilir.

Özet

Herkese açık yöntemler

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

Belirtilen temsilci yürütücüsüne yetki veren bir ExecutorService oluşturur.

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)

Korunan yöntemler

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

Herkese açık yöntemler

awaitTermination

public boolean awaitTermination (long timeout, 
                TimeUnit unit)

Parametreler
timeout long

unit TimeUnit

Döndürülenler
boolean

Verdiği hatalar
InterruptedException

create

public static TracePropagatingExecutorService create (ExecutorService delegate)

Belirtilen temsilci yürütücüsüne yetki veren bir ExecutorService oluşturur.

Görevlere yayılan etkin izlemenin, yürütücü yöntemine yapılan çağrılarda etkin olan izleme olduğunu unutmayın. Bunun nedeni, TF'nin çoğu nesneyi çağırmayı başlatmadan ve izi eklemeden önce oluşturmasıdır.

Parametreler
delegate ExecutorService

İadeler
TracePropagatingExecutorService

execute

public void execute (Runnable command)

Parametreler
command Runnable

invokeAll

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

Parametreler
tasks Collection

Döndürülenler
List<Future<T>>

Verdiği hatalar
InterruptedException

invokeAll

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

Parametreler
tasks Collection

timeout long

unit TimeUnit

Döndürülenler
List<Future<T>>

Verdiği hatalar
InterruptedException

invokeAny

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

Parametreler
tasks Collection

Döndürülenler
T

Verdiği hatalar
ExecutionException
InterruptedException

invokeAny

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

Parametreler
tasks Collection

timeout long

unit TimeUnit

Döndürülenler
T

Verdiği hatalar
ExecutionException
InterruptedException
TimeoutException

isShutdown

public boolean isShutdown ()

İadeler
boolean

isTerminated

public boolean isTerminated ()

İadeler
boolean

shutdown

public void shutdown ()

shutdownNow

public List<Runnable> shutdownNow ()

İadeler
List<Runnable>

submit

public Future<?> submit (Runnable task)

Parametreler
task Runnable

İadeler
Future<?>

submit

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

Parametreler
task Callable

İadeler
Future<T>

submit

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

Parametreler
task Runnable

result T

İadeler
Future<T>

Korunan yöntemler

wrapTasks

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

Parametreler
tasks Collection

Return'ler
Collection<? extends Callable<T>>