AbstractBoundedNodeQueue<T> |
Lock-free bounded non-blocking multiple-producer single-consumer queue based on the works of:
Andriy Plokhotnuyk (https://github.com/plokhotnyuk)
- https://github.com/plokhotnyuk/actors/blob/2e65abb7ce4cbfcb1b29c98ee99303d6ced6b01f/src/test/scala/akka/dispatch/Mailboxes.scala
(Apache V2: https://github.com/plokhotnyuk/actors/blob/master/LICENSE)
Dmitriy Vyukov's non-intrusive MPSC queue:
- https://www.1024cores.net/home/lock-free-algorithms/queues/non-intrusive-mpsc-node-based-queue
(Simplified BSD)
|
AbstractBoundedNodeQueue.Node<T> |
|
AbstractNodeQueue<T> |
Lock-free MPSC linked queue implementation based on Dmitriy Vyukov's non-intrusive MPSC queue:
https://www.1024cores.net/home/lock-free-algorithms/queues/non-intrusive-mpsc-node-based-queue
This queue could be wait-free (i.e.
|
AbstractNodeQueue.Node<T> |
|
BalancingDispatcherConfigurator |
Configurator for creating pekko.dispatch.BalancingDispatcher .
|
BalancingDispatcherConfigurator$ |
INTERNAL API
|
BoundedControlAwareMailbox |
BoundedControlAwareMailbox is a bounded MailboxType, that maintains two queues
to allow messages that extend pekko.dispatch.ControlMessage to be delivered with priority.
|
BoundedControlAwareMailbox.MessageQueue |
|
BoundedControlAwareMailbox$ |
|
BoundedDequeBasedMailbox |
BoundedDequeBasedMailbox is an bounded MailboxType, backed by a Deque.
|
BoundedDequeBasedMailbox.MessageQueue |
|
BoundedDequeBasedMailbox$ |
|
BoundedMailbox |
BoundedMailbox is the default bounded MailboxType used by Pekko Actors.
|
BoundedMailbox.MessageQueue |
|
BoundedMailbox$ |
|
BoundedNodeMessageQueue |
Lock-free bounded non-blocking multiple-producer single-consumer queue.
|
BoundedPriorityMailbox |
BoundedPriorityMailbox is a bounded mailbox that allows for prioritization of its contents.
|
BoundedPriorityMailbox.MessageQueue |
|
BoundedPriorityMailbox$ |
|
BoundedStablePriorityMailbox |
BoundedStablePriorityMailbox is a bounded mailbox that allows for prioritization of its contents.
|
BoundedStablePriorityMailbox.MessageQueue |
|
BoundedStablePriorityMailbox$ |
|
CachingConfig$ |
INTERNAL API
|
DefaultDispatcherPrerequisites$ |
|
DefaultExecutorServiceConfigurator |
|
Dispatcher |
The event-based Dispatcher binds a set of Actors to a thread pool backed up by a
BlockingQueue .
|
DispatcherConfigurator |
Configurator for creating pekko.dispatch.Dispatcher .
|
Dispatchers |
Dispatchers are to be defined in configuration to allow for tuning
for different environments.
|
Dispatchers$ |
|
Envelope |
|
Envelope$ |
|
ExecutionContexts |
ExecutionContexts is the Java API for ExecutionContexts
|
ExecutionContexts.sameThreadExecutionContext$ |
Deprecated.
|
ExecutionContexts$ |
ExecutionContexts is the Java API for ExecutionContexts
|
ExecutorServiceConfigurator |
An ExecutorServiceConfigurator is a class that given some prerequisites and a configuration can create instances of ExecutorService
|
Filter |
Java API (not recommended):
Callback for the Future.filter operation that creates a new Future which will
conditionally contain the success of another Future.
|
Filter$ |
Java API (not recommended):
Callback for the Future.filter operation that creates a new Future which will
conditionally contain the success of another Future.
|
Foreach<T> |
Callback for the Future.foreach operation that will be invoked if the Future that this callback
is registered on becomes completed with a success.
|
ForkJoinExecutorConfigurator |
|
ForkJoinExecutorConfigurator.PekkoForkJoinPool |
INTERNAL PEKKO USAGE ONLY
|
ForkJoinExecutorConfigurator.PekkoForkJoinTask |
INTERNAL PEKKO USAGE ONLY
|
ForkJoinExecutorConfigurator$ |
|
ForkJoinPoolConstants |
|
ForkJoinPoolConstants$ |
|
Futures |
Futures is the Java API for Futures and Promises
|
Futures$ |
Futures is the Java API for Futures and Promises
|
japi |
This class contains bridge classes between Scala and Java.
|
japi.BooleanFunctionBridge<T> |
Deprecated.
|
japi.CallbackBridge<T> |
Deprecated.
|
japi.RecoverBridge<T> |
Deprecated.
|
japi.UnitFunctionBridge<T> |
Deprecated.
|
japi$ |
This class contains bridge classes between Scala and Java.
|
Mailbox$ |
INTERNAL API
|
Mailboxes$ |
|
Mapper<T,R> |
Callback for the Future.map and Future.flatMap operations that will be invoked
if the Future that this callback is registered on becomes completed with a success.
|
MessageDispatcher |
|
MessageDispatcher$ |
INTERNAL API
|
MessageDispatcherConfigurator |
Base class to be used for hooking in new dispatchers into Dispatchers.
|
MonitorableThreadFactory |
|
MonitorableThreadFactory$ |
|
NodeMessageQueue |
|
NonBlockingBoundedMailbox |
NonBlockingBoundedMailbox is a high-performance, multiple-producer single-consumer, bounded MailboxType,
Noteworthy is that it discards overflow as DeadLetters.
|
NonBlockingBoundedMailbox$ |
|
OnComplete<T> |
Callback for when a Future is completed with either failure or a success
SAM (Single Abstract Method) class
|
OnFailure |
Callback for when a Future is completed with a failure
SAM (Single Abstract Method) class
|
OnSuccess<T> |
Callback for when a Future is completed successfully
SAM (Single Abstract Method) class
|
PinnedDispatcher |
Dedicates a unique thread for each actor passed in as reference.
|
PinnedDispatcherConfigurator |
Configurator for creating pekko.dispatch.PinnedDispatcher .
|
PriorityGenerator |
A PriorityGenerator is a convenience API to create a Comparator that orders the messages of a
PriorityDispatcher
|
PriorityGenerator$ |
|
Recover<T> |
Callback for the Future.recover operation that conditionally turns failures into successes.
|
SaneRejectedExecutionHandler |
The RejectedExecutionHandler used by Akka, it improves on CallerRunsPolicy
by throwing a RejectedExecutionException if the executor isShutdown.
|
SingleConsumerOnlyUnboundedMailbox |
SingleConsumerOnlyUnboundedMailbox is a high-performance, multiple producer—single consumer, unbounded MailboxType,
with the drawback that you can't have multiple consumers,
which rules out using it with BalancingPool (BalancingDispatcher) for instance.
|
SingleConsumerOnlyUnboundedMailbox$ |
|
TaskInvocation |
|
TaskInvocation$ |
|
ThreadPoolConfig |
|
ThreadPoolConfig$ |
|
ThreadPoolConfigBuilder |
A DSL to configure and create a MessageDispatcher with a ThreadPoolExecutor
|
ThreadPoolConfigBuilder$ |
|
ThreadPoolExecutorConfigurator |
|
UnboundedControlAwareMailbox |
UnboundedControlAwareMailbox is an unbounded MailboxType, that maintains two queues
to allow messages that extend pekko.dispatch.ControlMessage to be delivered with priority.
|
UnboundedControlAwareMailbox.MessageQueue |
|
UnboundedControlAwareMailbox$ |
|
UnboundedDequeBasedMailbox |
UnboundedDequeBasedMailbox is an unbounded MailboxType, backed by a Deque.
|
UnboundedDequeBasedMailbox.MessageQueue |
|
UnboundedDequeBasedMailbox$ |
|
UnboundedMailbox |
UnboundedMailbox is the default unbounded MailboxType used by Pekko Actors.
|
UnboundedMailbox.MessageQueue |
|
UnboundedMailbox$ |
|
UnboundedPriorityMailbox |
UnboundedPriorityMailbox is an unbounded mailbox that allows for prioritization of its contents.
|
UnboundedPriorityMailbox.MessageQueue |
|
UnboundedPriorityMailbox$ |
|
UnboundedStablePriorityMailbox |
UnboundedStablePriorityMailbox is an unbounded mailbox that allows for prioritization of its contents.
|
UnboundedStablePriorityMailbox.MessageQueue |
|
UnboundedStablePriorityMailbox$ |
|
VirtualThreadExecutorConfigurator |
|
VirtualThreadSupport |
|
VirtualThreadSupport$ |
|