net.dempsy.ringbuffer

Class RingBufferConsumerIterator<T>

java.lang.Object

net.dempsy.ringbuffer.RingBufferConsumerIterator<T>

public class RingBufferConsumerIterator<T>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	RingBufferConsumerIterator.Consumer<R>

Constructor Summary

Constructors

Constructor and Description
RingBufferConsumerIterator(Iterator<T> delegate, int queueSizePowerOf2, int numConsumers)
RingBufferConsumerIterator(Iterator<T> delegate, RingBufferConsumerIterator.Consumer<T>[] consumers, int queueSizePowerOf2, boolean runPublishSycnronously)

Method Summary

Modifier and Type	Method and Description
Iterator<T>[]	getIterators()
void	waitForCompletion()
void	waitForPublishToComplete()

Methods inherited from class java.lang.Object

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

Constructor Detail

RingBufferConsumerIterator

public RingBufferConsumerIterator(Iterator<T> delegate,
                                  int queueSizePowerOf2,
                                  int numConsumers)

RingBufferConsumerIterator

public RingBufferConsumerIterator(Iterator<T> delegate,
                                  RingBufferConsumerIterator.Consumer<T>[] consumers,
                                  int queueSizePowerOf2,
                                  boolean runPublishSycnronously)

Method Detail

getIterators

public Iterator<T>[] getIterators()

waitForPublishToComplete

public void waitForPublishToComplete()
                              throws InterruptedException

Throws:

InterruptedException

waitForCompletion

public void waitForCompletion()
                       throws InterruptedException

Throws:

InterruptedException