TracePropagatingExecutorService

public final class TracePropagatingExecutorService
extends Object implements ExecutorService

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


Một dịch vụ thực thi chuyển các tác vụ đến một quá trình triển khai cơ bản trong khi truyền ngữ cảnh theo dõi.

Điều này cho phép sử dụng các cơ sở theo dõi như CloseableTraceScope trong các tác vụ đã gửi.

Tóm tắt

Phương thức công khai

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

Tạo một ExecutorService uỷ quyền cho trình thực thi uỷ quyền đã cho.

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)

Phương thức được bảo vệ

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

Phương thức công khai

awaitTermination

public boolean awaitTermination (long timeout, 
                TimeUnit unit)

Tham số
timeout long

unit TimeUnit

Giá trị trả về
boolean

Gửi
InterruptedException

create

public static TracePropagatingExecutorService create (ExecutorService delegate)

Tạo một ExecutorService uỷ quyền cho trình thực thi uỷ quyền đã cho.

Xin lưu ý rằng dấu vết đang hoạt động được truyền đến các tác vụ là dấu vết đang hoạt động trên các lệnh gọi đến phương thức thực thi. Điều này là do TF tạo hầu hết các đối tượng trước khi bắt đầu lời gọi và đính kèm dấu vết.

Tham số
delegate ExecutorService

Giá trị trả về
TracePropagatingExecutorService

thực thi

public void execute (Runnable command)

Tham số
command Runnable

invokeAll

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

Tham số
tasks Collection

Giá trị trả về
List<Future<T>>

Gửi
InterruptedException

invokeAll

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

Tham số
tasks Collection

timeout long

unit TimeUnit

Giá trị trả về
List<Future<T>>

Gửi
InterruptedException

invokeAny

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

Tham số
tasks Collection

Giá trị trả về
T

Gửi
ExecutionException
InterruptedException

invokeAny

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

Tham số
tasks Collection

timeout long

unit TimeUnit

Giá trị trả về
T

Gửi
ExecutionException
InterruptedException
TimeoutException

isShutdown

public boolean isShutdown ()

Giá trị trả về
boolean

isTerminated

public boolean isTerminated ()

Giá trị trả về
boolean

tắt

public void shutdown ()

shutdownNow

public List<Runnable> shutdownNow ()

Giá trị trả về
List<Runnable>

gửi

public Future<?> submit (Runnable task)

Tham số
task Runnable

Giá trị trả về
Future<?>

gửi

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

Tham số
task Callable

Giá trị trả về
Future<T>

gửi

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

Tham số
task Runnable

result T

Giá trị trả về
Future<T>

Phương thức được bảo vệ

wrapTasks

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

Tham số
tasks Collection

Trả về
Collection<? extends Callable<T>>