Google is committed to advancing racial equity for Black communities. See how.

ParallelDeviceExecutor

public class ParallelDeviceExecutor
extends Object

java.lang.Object
   ↳ com.android.tradefed.util.executor.ParallelDeviceExecutor<V>


Wrapper of ERROR(/ExecutorService) to execute a function in parallel.

Summary

Public constructors

ParallelDeviceExecutor(int poolSize)

Public methods

getErrors()

The list of errors from the execution of all tasks.

boolean hasErrors()

Whether or not some errors occurred or not.

invokeAll( callableTasks, long timeout, TimeUnit unit)

Invoke all the ERROR(/Callable) with the timeout limit.

Public constructors

ParallelDeviceExecutor

public ParallelDeviceExecutor (int poolSize)

Parameters
poolSize int

Public methods

getErrors

public  getErrors ()

The list of errors from the execution of all tasks.

Returns

hasErrors

public boolean hasErrors ()

Whether or not some errors occurred or not.

Returns
boolean

invokeAll

public  invokeAll ( callableTasks, 
                long timeout, 
                TimeUnit unit)

Invoke all the ERROR(/Callable) with the timeout limit.

Parameters
callableTasks : The List of tasks.

timeout long: The timeout to apply, or zero for unlimited.

unit TimeUnit: The unit of the timeout.

Returns
The list of results for each callable task.