com.googlecode.junittoolbox

Class MultithreadingTester

java.lang.Object

com.googlecode.junittoolbox.MultithreadingTester

public class MultithreadingTester
extends Object

Runs one ore more RunnableAsserts concurrently in multiple threads several times. Use this class for testing the robustness of thread-safe code like this:

     new MultithreadingTester().add(...).run();
 

If an Exception or Error is caught in any of the threads, the run() method (and therefore the test which calls the run() methods) will fail. Per default 100 threads are used whereby each thread executes its RunnableAssert 1000 times. You can change these settings like this:

     new MultithreadingTester().numThreads(...)
                               .numRoundsPerThread(...)
                               .add(...)
                               .run();
 

Constructor Summary

Constructors

Constructor and Description
MultithreadingTester()

Method Summary

Modifier and Type	Method and Description
MultithreadingTester	add(Callable<?> callable, Callable<?>... moreCallables) Converts the given Callables into RunnableAsserts and adds them to this MultithreadingTester, returns this to allow method chaining.
MultithreadingTester	add(Collection<RunnableAssert> runnableAsserts) Adds the given RunnableAsserts to this MultithreadingTester, returns this to allow method chaining.
MultithreadingTester	add(RunnableAssert runnableAssert, RunnableAssert... moreRunnableAsserts) Adds the given RunnableAsserts to this MultithreadingTester, returns this to allow method chaining.
MultithreadingTester	add(Runnable runnable, Runnable... moreRunnables) Converts the given Runnables into RunnableAsserts and adds them to this MultithreadingTester, returns this to allow method chaining.
MultithreadingTester	numRoundsPerThread(int roundsPerThreads) Sets the number of rounds per thread, default is 1000, returns this to allow method chaining.
MultithreadingTester	numThreads(int numThreads) Sets the number of threads used by run(), default is 100, returns this to allow method chaining.
void	run() Starts multiple threads, which execute the added RunnableAsserts several times.

Methods inherited from class java.lang.Object

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

Constructor Detail

MultithreadingTester

public MultithreadingTester()

Method Detail

numThreads

public MultithreadingTester numThreads(int numThreads)

Sets the number of threads used by run(), default is 100, returns this to allow method chaining.

numRoundsPerThread

public MultithreadingTester numRoundsPerThread(int roundsPerThreads)

Sets the number of rounds per thread, default is 1000, returns this to allow method chaining.

add

public MultithreadingTester add(@Nonnull
                                RunnableAssert runnableAssert,
                                RunnableAssert... moreRunnableAsserts)

Adds the given RunnableAsserts to this MultithreadingTester, returns this to allow method chaining.

add

public MultithreadingTester add(@Nonnull
                                Collection<RunnableAssert> runnableAsserts)

Adds the given RunnableAsserts to this MultithreadingTester, returns this to allow method chaining.

add

public MultithreadingTester add(@Nonnull
                                Runnable runnable,
                                Runnable... moreRunnables)

Converts the given Runnables into RunnableAsserts and adds them to this MultithreadingTester, returns this to allow method chaining.

add

public MultithreadingTester add(@Nonnull
                                Callable<?> callable,
                                Callable<?>... moreCallables)

Converts the given Callables into RunnableAsserts and adds them to this MultithreadingTester, returns this to allow method chaining.

run

public void run()

Starts multiple threads, which execute the added RunnableAsserts several times. This method blocks until all started threads are finished. If an Exception or Error is caught in any of the started threads, this method will also throw an Exception or Error.

See Also:

numThreads(int), numRoundsPerThread(int)