Package | Description |
---|---|
reactor.core |
Core components of the Reactor framework.
|
reactor.core.dispatch |
Dispatchers provide a way for work to be done in another thread,
but unlike a standard thread pool, do so with extreme efficiency. |
reactor.core.processor |
This package offers a suite of asynchronous
Processor with backpressure support. |
Modifier and Type | Interface and Description |
---|---|
interface |
Dispatcher
A
Dispatcher is used to Dispatcher.dispatch(Object, Consumer, Consumer)
dispatch} data to Consumer s. |
interface |
DispatcherSupplier
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractLifecycleDispatcher
A
Dispatcher that has a lifecycle. |
class |
MpscDispatcher
Implementation of a
Dispatcher that uses a MpscLinkedQueue to
queue tasks to execute. |
class |
MultiThreadDispatcher
Base implementation for multi-threaded dispatchers
|
class |
RingBufferDispatcher
Implementation of a
Dispatcher that uses a RingBuffer to queue tasks to execute. |
class |
SingleThreadDispatcher
Base Implementation for single-threaded Dispatchers.
|
class |
SynchronousDispatcher
A
Dispatcher implementation that dispatches events using the calling thread. |
class |
TailRecurseDispatcher
A
Dispatcher implementation that trampolines events using the calling thread and. |
class |
ThreadPoolExecutorDispatcher
A
Dispatcher that uses a ThreadPoolExecutor with an unbounded queue to dispatch events. |
class |
TraceableDelegatingDispatcher
An implementation of
Dispatcher that traces activity through it. |
class |
WorkQueueDispatcher
Implementation of a
Dispatcher that uses a multi-threaded, multi-producer RingBuffer to queue tasks
to execute. |
Modifier and Type | Class and Description |
---|---|
class |
ExecutorPoweredProcessor<IN,OUT>
A base processor used by executor backed processors to take care of their ExecutorService
|
class |
ReactorProcessor<IN,OUT>
A base processor
|
class |
RingBufferProcessor<E>
An implementation of a RingBuffer backed message-passing Processor.
|
class |
RingBufferWorkProcessor<E>
An implementation of a RingBuffer backed message-passing WorkProcessor.
|
Copyright © 2017. All rights reserved.