Class ConcurrentProducerConsumer

java.lang.Object

is.galia.util.ConcurrentProducerConsumer

public final class ConcurrentProducerConsumer
extends Object

Concurrently pits a consumer against a producer. Used only for testing, but located here in order to be shareable to plugins.

Constructor Summary

Constructors

Constructor	Description
ConcurrentProducerConsumer(Callable<Void> producer, Callable<Void> consumer)
ConcurrentProducerConsumer(Callable<Void> producer, Callable<Void> consumer, int numThreads)

Method Summary

Modifier and Type	Method	Description
ConcurrentProducerConsumer	numThreads(int count)
void	run()

Methods inherited from class java.lang.Object

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

Constructor Details

ConcurrentProducerConsumer

public ConcurrentProducerConsumer(Callable<Void> producer,
 Callable<Void> consumer)

ConcurrentProducerConsumer

public ConcurrentProducerConsumer(Callable<Void> producer,
 Callable<Void> consumer,
 int numThreads)

Method Details

run

public void run()
         throws Exception

Throws:

Exception

numThreads

public ConcurrentProducerConsumer numThreads(int count)