Package | Description |
---|---|
reactor.core.processor |
This package offers a suite of asynchronous
Processor with backpressure support. |
Modifier and Type | Method and Description |
---|---|
static <E> RingBufferWorkProcessor<E> |
RingBufferWorkProcessor.create()
Create a new RingBufferWorkProcessor using
ReactorProcessor.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy
and auto-cancel. |
static <E> RingBufferWorkProcessor<E> |
RingBufferWorkProcessor.create(boolean autoCancel)
Create a new RingBufferWorkProcessor using
ReactorProcessor.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy
and the passed auto-cancel setting. |
static <E> RingBufferWorkProcessor<E> |
RingBufferWorkProcessor.create(ExecutorService service)
Create a new RingBufferWorkProcessor using
ReactorProcessor.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy
and auto-cancel. |
static <E> RingBufferWorkProcessor<E> |
RingBufferWorkProcessor.create(ExecutorService service,
boolean autoCancel)
Create a new RingBufferWorkProcessor using
ReactorProcessor.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy
and the passed auto-cancel setting. |
static <E> RingBufferWorkProcessor<E> |
RingBufferWorkProcessor.create(ExecutorService service,
int bufferSize)
Create a new RingBufferProcessor using the passed buffer size, blockingWait Strategy
and auto-cancel.
|
static <E> RingBufferWorkProcessor<E> |
RingBufferWorkProcessor.create(ExecutorService service,
int bufferSize,
boolean autoCancel)
Create a new RingBufferWorkProcessor using the passed buffer size, blockingWait Strategy
and auto-cancel.
|
static <E> RingBufferWorkProcessor<E> |
RingBufferWorkProcessor.create(ExecutorService executor,
int bufferSize,
com.lmax.disruptor.WaitStrategy strategy)
Create a new RingBufferWorkProcessor using the passed buffer size and blockingWait Strategy settings
but will auto-cancel.
|
static <E> RingBufferWorkProcessor<E> |
RingBufferWorkProcessor.create(ExecutorService executor,
int bufferSize,
com.lmax.disruptor.WaitStrategy strategy,
boolean autoCancel)
Create a new RingBufferWorkProcessor using the passed buffer size, wait strategy
and auto-cancel settings.
|
static <E> RingBufferWorkProcessor<E> |
RingBufferWorkProcessor.create(String name,
int bufferSize)
Create a new RingBufferProcessor using the passed buffer size, blockingWait Strategy
and auto-cancel.
|
static <E> RingBufferWorkProcessor<E> |
RingBufferWorkProcessor.create(String name,
int bufferSize,
boolean autoCancel)
Create a new RingBufferProcessor using the passed buffer size, blockingWait Strategy
and the passed auto-cancel setting.
|
static <E> RingBufferWorkProcessor<E> |
RingBufferWorkProcessor.create(String name,
int bufferSize,
com.lmax.disruptor.WaitStrategy strategy)
Create a new RingBufferWorkProcessor using the passed buffer size, blockingWait Strategy
and auto-cancel.
|
static <E> RingBufferWorkProcessor<E> |
RingBufferWorkProcessor.create(String name,
int bufferSize,
com.lmax.disruptor.WaitStrategy strategy,
boolean autoCancel)
Create a new RingBufferWorkProcessor using the passed buffer size, blockingWait Strategy
and auto-cancel settings.
|
static <E> RingBufferWorkProcessor<E> |
RingBufferWorkProcessor.share()
Create a new RingBufferWorkProcessor using
ReactorProcessor.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy
and auto-cancel. |
static <E> RingBufferWorkProcessor<E> |
RingBufferWorkProcessor.share(boolean autoCancel)
Create a new RingBufferWorkProcessor using
ReactorProcessor.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy
and the passed auto-cancel setting. |
static <E> RingBufferWorkProcessor<E> |
RingBufferWorkProcessor.share(ExecutorService service)
Create a new RingBufferWorkProcessor using
ReactorProcessor.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy
and auto-cancel. |
static <E> RingBufferWorkProcessor<E> |
RingBufferWorkProcessor.share(ExecutorService service,
boolean autoCancel)
Create a new RingBufferWorkProcessor using
ReactorProcessor.SMALL_BUFFER_SIZE backlog size, blockingWait Strategy
and the passed auto-cancel setting. |
static <E> RingBufferWorkProcessor<E> |
RingBufferWorkProcessor.share(ExecutorService service,
int bufferSize)
Create a new RingBufferProcessor using the passed buffer size, blockingWait Strategy
and auto-cancel.
|
static <E> RingBufferWorkProcessor<E> |
RingBufferWorkProcessor.share(ExecutorService service,
int bufferSize,
boolean autoCancel)
Create a new RingBufferWorkProcessor using the passed buffer size, blockingWait Strategy
and auto-cancel.
|
static <E> RingBufferWorkProcessor<E> |
RingBufferWorkProcessor.share(ExecutorService executor,
int bufferSize,
com.lmax.disruptor.WaitStrategy strategy)
Create a new RingBufferWorkProcessor using the passed buffer size and blockingWait Strategy settings
but will auto-cancel.
|
static <E> RingBufferWorkProcessor<E> |
RingBufferWorkProcessor.share(ExecutorService executor,
int bufferSize,
com.lmax.disruptor.WaitStrategy strategy,
boolean autoCancel)
Create a new RingBufferWorkProcessor using the passed buffer size, wait strategy
and auto-cancel settings.
|
static <E> RingBufferWorkProcessor<E> |
RingBufferWorkProcessor.share(String name,
int bufferSize)
Create a new RingBufferProcessor using the passed buffer size, blockingWait Strategy
and auto-cancel.
|
static <E> RingBufferWorkProcessor<E> |
RingBufferWorkProcessor.share(String name,
int bufferSize,
boolean autoCancel)
Create a new RingBufferProcessor using the passed buffer size, blockingWait Strategy
and the passed auto-cancel setting.
|
static <E> RingBufferWorkProcessor<E> |
RingBufferWorkProcessor.share(String name,
int bufferSize,
com.lmax.disruptor.WaitStrategy strategy)
Create a new RingBufferWorkProcessor using the passed buffer size, blockingWait Strategy
and auto-cancel.
|
static <E> RingBufferWorkProcessor<E> |
RingBufferWorkProcessor.share(String name,
int bufferSize,
com.lmax.disruptor.WaitStrategy strategy,
boolean autoCancel)
Create a new RingBufferWorkProcessor using the passed buffer size, blockingWait Strategy
and auto-cancel settings.
|
Copyright © 2016. All rights reserved.