Class Blitzer

java.lang.Object

org.jmock.lib.concurrent.Blitzer

public class Blitzer
extends Object

A class that "blitzes" an object by calling it many times, from multiple threads. Used for stress-testing synchronisation.

Field Summary

Fields

Modifier and Type	Field	Description
private final int	actionCount
static final int	DEFAULT_THREAD_COUNT	The default number of threads to run concurrently.
private final ExecutorService	executorService

Constructor Summary

Constructors

Constructor	Description
Blitzer(int actionCount)
Blitzer(int actionCount, int threadCount)
Blitzer(int actionCount, int threadCount, ThreadFactory threadFactory)
Blitzer(int actionCount, ExecutorService executorService)

Method Summary

Modifier and Type	Method	Description
void	blitz(long timeoutMs, Runnable action)
void	blitz(Runnable action)
void	shutdown()
private CountDownLatch	spawnThreads(Runnable action)
int	totalActionCount()

Methods inherited from class Object

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

Field Details

DEFAULT_THREAD_COUNT

public static final int DEFAULT_THREAD_COUNT

The default number of threads to run concurrently.

See Also:

• Constant Field Values

executorService

private final ExecutorService executorService

actionCount

private final int actionCount

Constructor Details

Blitzer

public Blitzer(int actionCount)

Blitzer

public Blitzer(int actionCount,
 int threadCount)

Blitzer

public Blitzer(int actionCount,
 int threadCount,
 ThreadFactory threadFactory)

Blitzer

public Blitzer(int actionCount,
 ExecutorService executorService)

Method Details

totalActionCount

public int totalActionCount()

blitz

public void blitz(Runnable action)
           throws InterruptedException

Throws:

InterruptedException

blitz

public void blitz(long timeoutMs,
 Runnable action)
           throws InterruptedException,
TimeoutException

Throws:

InterruptedException

TimeoutException

spawnThreads

private CountDownLatch spawnThreads(Runnable action)

shutdown

public void shutdown()