reactor.alloc

Class RingBufferAllocator<T extends Recyclable>

java.lang.Object

reactor.alloc.RingBufferAllocator<T>

All Implemented Interfaces:

Allocator<T>

public class RingBufferAllocator<T extends Recyclable>
extends java.lang.Object
implements Allocator<T>

An Allocator implementation based int the LMAX Disruptor RingBuffer.

Since:

1.1

Constructor Summary

Constructors

Constructor and Description
RingBufferAllocator(java.lang.String name, int poolSize, Supplier<T> poolFactory)
RingBufferAllocator(java.lang.String name, int poolSize, Supplier<T> poolFactory, int eventThreads)
RingBufferAllocator(java.lang.String name, int poolSize, Supplier<T> poolFactory, int eventThreads, com.lmax.disruptor.EventHandler<Reference<T>> eventHandler, com.lmax.disruptor.ExceptionHandler errorHandler, com.lmax.disruptor.dsl.ProducerType producerType, com.lmax.disruptor.WaitStrategy waitStrategy, java.util.concurrent.ExecutorService executor)

Method Summary

Modifier and Type	Method and Description
boolean	alive()
Reference<T>	allocate() Allocate an object from the internal pool.
java.util.List<Reference<T>>	allocateBatch(int size) Allocate a batch of objects all at once.
java.util.List<Reference<T>>	allocateBatch(int size, java.util.List<Reference<T>> refs)
boolean	awaitAndShutdown()
boolean	awaitAndShutdown(long timeout, java.util.concurrent.TimeUnit timeUnit)
void	halt()
void	release(java.util.List<Reference<T>> batch) Efficiently release a batch of References all at once.
void	shutdown()
void	start()

Methods inherited from class java.lang.Object

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

Constructor Detail

RingBufferAllocator

public RingBufferAllocator(java.lang.String name,
                           int poolSize,
                           Supplier<T> poolFactory)

RingBufferAllocator

public RingBufferAllocator(java.lang.String name,
                           int poolSize,
                           Supplier<T> poolFactory,
                           int eventThreads)

RingBufferAllocator

public RingBufferAllocator(java.lang.String name,
                           int poolSize,
                           Supplier<T> poolFactory,
                           int eventThreads,
                           com.lmax.disruptor.EventHandler<Reference<T>> eventHandler,
                           com.lmax.disruptor.ExceptionHandler errorHandler,
                           com.lmax.disruptor.dsl.ProducerType producerType,
                           com.lmax.disruptor.WaitStrategy waitStrategy,
                           java.util.concurrent.ExecutorService executor)

Method Detail

allocate

public Reference<T> allocate()

Description copied from interface: Allocator

Allocate an object from the internal pool.

Specified by:

allocate in interface Allocator<T extends Recyclable>

Returns:

a Reference that can be retained and released.

allocateBatch

public java.util.List<Reference<T>> allocateBatch(int size,
                                                  java.util.List<Reference<T>> refs)

allocateBatch

public java.util.List<Reference<T>> allocateBatch(int size)

Description copied from interface: Allocator

Allocate a batch of objects all at once.

Specified by:

allocateBatch in interface Allocator<T extends Recyclable>

Parameters:

size - the number of objects to allocate

Returns:

a List of References to the allocated objects

release

public void release(java.util.List<Reference<T>> batch)

Description copied from interface: Allocator

Efficiently release a batch of References all at once.

Specified by:

release in interface Allocator<T extends Recyclable>

Parameters:

batch - the references to release

alive

public boolean alive()

start

public void start()

awaitAndShutdown

public boolean awaitAndShutdown()

awaitAndShutdown

public boolean awaitAndShutdown(long timeout,
                                java.util.concurrent.TimeUnit timeUnit)

shutdown

public void shutdown()

halt

public void halt()