org.modeshape.jcr.bus

Class RepositoryRingBufferBuilder<T,C>

java.lang.Object

org.modeshape.common.collection.ring.RingBufferBuilder<T,C>

org.modeshape.jcr.bus.RepositoryRingBufferBuilder<T,C>

Type Parameters:

T - the type of entries stored in the buffer

C - the type of consumer

public final class RepositoryRingBufferBuilder<T,C>
extends RingBufferBuilder<T,C>

An extension to the RingBufferBuilder which adds functionality required by the repository.

See Also:

RingBufferBuilder

Field Summary

Fields inherited from class org.modeshape.common.collection.ring.RingBufferBuilder

DEFAULT_BUFFER_SIZE, DEFAULT_GARBAGE_COLLECT_ENTITIES, DEFAULT_NAME

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	RepositoryRingBufferBuilder(Executor executor, RingBuffer.ConsumerAdapter<T,C> adapter, RepositoryStatistics statistics)

Method Summary

Modifier and Type	Method and Description
protected Cursor	defaultCursor(int bufferSize, WaitStrategy waitStrategy)
static <T,C> RingBufferBuilder<T,C>	withMultipleProducers(Executor executor, RingBuffer.ConsumerAdapter<T,C> adapter, RepositoryStatistics statistics) Create a builder for ring buffers that use the supplied Executor to create consumer threads and the supplied RingBuffer.ConsumerAdapter to adapt to custom consumer implementations.

Methods inherited from class org.modeshape.common.collection.ring.RingBufferBuilder

build, defaultWaitStrategy, garbageCollect, multipleProducers, named, ofSize, singleProducer, waitUsing, withMultipleProducers, withMultipleProducers, withSingleProducer, withSingleProducer

Methods inherited from class java.lang.Object

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

Constructor Detail

RepositoryRingBufferBuilder

protected RepositoryRingBufferBuilder(Executor executor,
                                      RingBuffer.ConsumerAdapter<T,C> adapter,
                                      RepositoryStatistics statistics)

Method Detail

withMultipleProducers

public static <T,C> RingBufferBuilder<T,C> withMultipleProducers(Executor executor,
                                                                 RingBuffer.ConsumerAdapter<T,C> adapter,
                                                                 RepositoryStatistics statistics)

Create a builder for ring buffers that use the supplied Executor to create consumer threads and the supplied RingBuffer.ConsumerAdapter to adapt to custom consumer implementations. The ring buffer will allow entries to be added from multiple threads.

Parameters:

executor - the executor that should be used to create threads to run consumers; may not be null

adapter - the adapter to the desired consumer interface; may not be null

statistics - a RepositoryStatistics instance; may be null.

Returns:

the builder for ring buffers; never null

See Also:

RingBufferBuilder.withMultipleProducers(Executor, RingBuffer.ConsumerAdapter)

defaultCursor

protected Cursor defaultCursor(int bufferSize,
                               WaitStrategy waitStrategy)

Overrides:

defaultCursor in class RingBufferBuilder<T,C>