public class Blitzer
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private int |
actionCount |
static int |
DEFAULT_THREAD_COUNT
The default number of threads to run concurrently.
|
private java.util.concurrent.ExecutorService |
executorService |
Constructor and Description |
---|
Blitzer(int actionCount) |
Blitzer(int actionCount,
java.util.concurrent.ExecutorService executorService) |
Blitzer(int actionCount,
int threadCount) |
Blitzer(int actionCount,
int threadCount,
java.util.concurrent.ThreadFactory threadFactory) |
Modifier and Type | Method and Description |
---|---|
void |
blitz(long timeoutMs,
java.lang.Runnable action) |
void |
blitz(java.lang.Runnable action) |
void |
shutdown() |
private java.util.concurrent.CountDownLatch |
spawnThreads(java.lang.Runnable action) |
int |
totalActionCount() |
public static final int DEFAULT_THREAD_COUNT
private final java.util.concurrent.ExecutorService executorService
private final int actionCount
public Blitzer(int actionCount)
public Blitzer(int actionCount, int threadCount)
public Blitzer(int actionCount, int threadCount, java.util.concurrent.ThreadFactory threadFactory)
public Blitzer(int actionCount, java.util.concurrent.ExecutorService executorService)
public int totalActionCount()
public void blitz(java.lang.Runnable action) throws java.lang.InterruptedException
java.lang.InterruptedException
public void blitz(long timeoutMs, java.lang.Runnable action) throws java.lang.InterruptedException, java.util.concurrent.TimeoutException
java.lang.InterruptedException
java.util.concurrent.TimeoutException
private java.util.concurrent.CountDownLatch spawnThreads(java.lang.Runnable action)
public void shutdown()