com.atlassian.crowd.test.rules

Class ExecutorServiceFactoryRule

java.lang.Object

com.atlassian.crowd.test.rules.ExecutorServiceFactoryRule

All Implemented Interfaces:

org.junit.rules.TestRule

public class ExecutorServiceFactoryRule
extends Object
implements org.junit.rules.TestRule

Helper test rule for running multithreading tests. Automatically shutdowns created ExecutorService.

Constructor Summary

Constructors

Constructor and Description
ExecutorServiceFactoryRule(Duration shutdownTimeout, boolean shutdownAllInterruptRunningTasks)

Method Summary

Modifier and Type	Method and Description
org.junit.runners.model.Statement	apply(org.junit.runners.model.Statement base, org.junit.runner.Description description)
ExecutorService	createExecutorService(int threads)
int	getExecutorServiceCount()
<T> List<T>	runConcurrently(int threadCount, Callable<T> task)
void	shutdownAll()
Duration	shutdownAndWait(ExecutorService executorService)
Duration	shutdownAndWait(ExecutorService executorService, Duration shutdownTimeout)

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecutorServiceFactoryRule

public ExecutorServiceFactoryRule(Duration shutdownTimeout,
                                  boolean shutdownAllInterruptRunningTasks)

Method Detail

createExecutorService

public ExecutorService createExecutorService(int threads)

shutdownAll

public void shutdownAll()
                 throws InterruptedException

Throws:

InterruptedException

shutdownAndWait

public Duration shutdownAndWait(ExecutorService executorService)
                         throws InterruptedException

Throws:

InterruptedException

shutdownAndWait

public Duration shutdownAndWait(ExecutorService executorService,
                                Duration shutdownTimeout)
                         throws InterruptedException

Throws:

InterruptedException

apply

public org.junit.runners.model.Statement apply(org.junit.runners.model.Statement base,
                                               org.junit.runner.Description description)

Specified by:

apply in interface org.junit.rules.TestRule

getExecutorServiceCount

public int getExecutorServiceCount()

runConcurrently

public <T> List<T> runConcurrently(int threadCount,
                                   Callable<T> task)
                            throws ExecutionException,
                                   InterruptedException

Throws:

ExecutionException

InterruptedException