Package org.robolectric.android.util.concurrent

Class PausedExecutorService

java.lang.Object

java.util.concurrent.AbstractExecutorService

org.robolectric.android.util.concurrent.PausedExecutorService

All Implemented Interfaces:

Executor, ExecutorService

@Beta
public class PausedExecutorService
extends AbstractExecutorService

Executor service that queues any posted tasks.

Users must explicitly call runAll() to execute all pending tasks.

Intended to be a replacement for RoboExecutorService when using LooperMode.Mode#PAUSED. Unlike RoboExecutorService, will execute tasks on a background thread. This is useful to test Android code that enforces it runs off the main thread.

NOTE: Beta API, subject to change.

Constructor Summary

Constructors

Constructor and Description
PausedExecutorService()

Method Summary

Modifier and Type	Method and Description
boolean	awaitTermination(long l, TimeUnit timeUnit)
void	execute(Runnable command)
boolean	hasQueuedTasks()
boolean	isShutdown()
boolean	isTerminated()
protected <T> RunnableFuture<T>	newTaskFor(Callable<T> callable)
protected <T> RunnableFuture<T>	newTaskFor(Runnable runnable, T value)
int	runAll() Execute all posted tasks and block until they are complete.
boolean	runNext() Executes the next queued task.
void	shutdown()
List<Runnable>	shutdownNow()

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, submit, submit, submit

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PausedExecutorService

public PausedExecutorService()

Method Detail

runAll

public int runAll()

Execute all posted tasks and block until they are complete.

Returns:

the number of tasks executed

runNext

public boolean runNext()

Executes the next queued task.

Will be ignored if called from the executor service thread to prevent deadlocks.

Returns:

true if task was run, false if queue was empty

hasQueuedTasks

public boolean hasQueuedTasks()

Returns:

true if there are queued pending tasks

shutdown

public void shutdown()

shutdownNow

public List<Runnable> shutdownNow()

isShutdown

public boolean isShutdown()

isTerminated

public boolean isTerminated()

awaitTermination

public boolean awaitTermination(long l,
                                TimeUnit timeUnit)
                         throws InterruptedException

Throws:

InterruptedException

execute

public void execute(@NonNull
                    Runnable command)

newTaskFor

protected <T> RunnableFuture<T> newTaskFor(Runnable runnable,
                                           T value)

Overrides:

newTaskFor in class AbstractExecutorService

newTaskFor

protected <T> RunnableFuture<T> newTaskFor(Callable<T> callable)

Overrides:

newTaskFor in class AbstractExecutorService