Class Hierarchy
- java.lang.Object
- org.apache.pekko.dispatch.AbstractBoundedNodeQueue<T>
- org.apache.pekko.dispatch.BoundedNodeMessageQueue (implements org.apache.pekko.dispatch.BoundedMessageQueueSemantics, org.apache.pekko.dispatch.MessageQueue, org.apache.pekko.dispatch.MultipleConsumerSemantics)
- org.apache.pekko.dispatch.AbstractBoundedNodeQueue.Node<T>
- java.util.AbstractCollection<E> (implements java.util.Collection<E>)
- java.util.AbstractQueue<E> (implements java.util.Queue<E>)
- org.apache.pekko.util.BoundedBlockingQueue<E> (implements java.util.concurrent.BlockingQueue<E>)
- org.apache.pekko.dispatch.BoundedPriorityMailbox.MessageQueue (implements org.apache.pekko.dispatch.BoundedQueueBasedMessageQueue)
- org.apache.pekko.dispatch.BoundedStablePriorityMailbox.MessageQueue (implements org.apache.pekko.dispatch.BoundedQueueBasedMessageQueue)
- java.util.concurrent.ConcurrentLinkedQueue<E> (implements java.util.Queue<E>, java.io.Serializable)
- org.apache.pekko.dispatch.UnboundedMailbox.MessageQueue (implements org.apache.pekko.dispatch.UnboundedQueueBasedMessageQueue)
- java.util.concurrent.LinkedBlockingDeque<E> (implements java.util.concurrent.BlockingDeque<E>, java.io.Serializable)
- org.apache.pekko.dispatch.BoundedDequeBasedMailbox.MessageQueue (implements org.apache.pekko.dispatch.BoundedDequeBasedMessageQueue)
- org.apache.pekko.dispatch.UnboundedDequeBasedMailbox.MessageQueue (implements org.apache.pekko.dispatch.UnboundedDequeBasedMessageQueue)
- java.util.concurrent.LinkedBlockingQueue<E> (implements java.util.concurrent.BlockingQueue<E>, java.io.Serializable)
- org.apache.pekko.dispatch.BoundedMailbox.MessageQueue (implements org.apache.pekko.dispatch.BoundedQueueBasedMessageQueue)
- java.util.concurrent.PriorityBlockingQueue<E> (implements java.util.concurrent.BlockingQueue<E>, java.io.Serializable)
- org.apache.pekko.dispatch.UnboundedPriorityMailbox.MessageQueue (implements org.apache.pekko.dispatch.UnboundedQueueBasedMessageQueue)
- org.apache.pekko.util.StablePriorityBlockingQueue<E> (implements org.apache.pekko.util.PriorityQueueStabilizer<E>)
- org.apache.pekko.dispatch.UnboundedStablePriorityMailbox.MessageQueue (implements org.apache.pekko.dispatch.UnboundedQueueBasedMessageQueue)
- org.apache.pekko.util.BoundedBlockingQueue<E> (implements java.util.concurrent.BlockingQueue<E>)
- java.util.AbstractQueue<E> (implements java.util.Queue<E>)
- java.util.concurrent.AbstractExecutorService (implements java.util.concurrent.ExecutorService)
- java.util.concurrent.ForkJoinPool
- org.apache.pekko.dispatch.ForkJoinExecutorConfigurator.PekkoForkJoinPool (implements org.apache.pekko.dispatch.LoadMetrics)
- java.util.concurrent.ForkJoinPool
- scala.runtime.AbstractFunction0<R> (implements scala.Function0<R>)
- org.apache.pekko.dispatch.SingleConsumerOnlyUnboundedMailbox$ (implements java.io.Serializable)
- scala.runtime.AbstractFunction1<T1,R> (implements scala.Function1<T1,R>)
- org.apache.pekko.dispatch.Mapper<T,R>
- org.apache.pekko.dispatch.NonBlockingBoundedMailbox$ (implements java.io.Serializable)
- org.apache.pekko.dispatch.ThreadPoolConfigBuilder$ (implements java.io.Serializable)
- scala.runtime.AbstractFunction3<T1,T2,T3,R> (implements scala.Function3<T1,T2,T3,R>)
- org.apache.pekko.dispatch.TaskInvocation$ (implements java.io.Serializable)
- scala.runtime.AbstractFunction7<T1,T2,T3,T4,T5,T6,T7,R> (implements scala.Function7<T1,T2,T3,T4,T5,T6,T7,R>)
- org.apache.pekko.dispatch.DefaultDispatcherPrerequisites$ (implements java.io.Serializable)
- org.apache.pekko.dispatch.AbstractNodeQueue.Node<T>
- scala.runtime.AbstractPartialFunction<T1,R> (implements scala.PartialFunction<A,B>)
- org.apache.pekko.dispatch.japi.CallbackBridge<T>
- org.apache.pekko.dispatch.OnComplete<T>
- org.apache.pekko.dispatch.OnFailure
- org.apache.pekko.dispatch.OnSuccess<T>
- org.apache.pekko.dispatch.japi.RecoverBridge<T>
- org.apache.pekko.dispatch.Recover<T>
- org.apache.pekko.dispatch.japi.CallbackBridge<T>
- java.util.concurrent.atomic.AtomicReference<V> (implements java.io.Serializable)
- org.apache.pekko.dispatch.AbstractNodeQueue<T>
- org.apache.pekko.dispatch.NodeMessageQueue (implements org.apache.pekko.dispatch.MessageQueue, org.apache.pekko.dispatch.UnboundedMessageQueueSemantics)
- org.apache.pekko.dispatch.AbstractNodeQueue<T>
- org.apache.pekko.dispatch.BalancingDispatcherConfigurator$
- org.apache.pekko.dispatch.BoundedControlAwareMailbox (implements org.apache.pekko.dispatch.MailboxType, org.apache.pekko.dispatch.ProducesMessageQueue<T>, org.apache.pekko.dispatch.ProducesPushTimeoutSemanticsMailbox, scala.Product, java.io.Serializable)
- org.apache.pekko.dispatch.BoundedControlAwareMailbox.MessageQueue (implements org.apache.pekko.dispatch.BoundedControlAwareMessageQueueSemantics, java.io.Serializable)
- org.apache.pekko.dispatch.BoundedControlAwareMailbox$ (implements java.io.Serializable)
- org.apache.pekko.dispatch.BoundedDequeBasedMailbox (implements org.apache.pekko.dispatch.MailboxType, org.apache.pekko.dispatch.ProducesMessageQueue<T>, org.apache.pekko.dispatch.ProducesPushTimeoutSemanticsMailbox, scala.Product, java.io.Serializable)
- org.apache.pekko.dispatch.BoundedDequeBasedMailbox$ (implements java.io.Serializable)
- org.apache.pekko.dispatch.BoundedMailbox (implements org.apache.pekko.dispatch.MailboxType, org.apache.pekko.dispatch.ProducesMessageQueue<T>, org.apache.pekko.dispatch.ProducesPushTimeoutSemanticsMailbox, scala.Product, java.io.Serializable)
- org.apache.pekko.dispatch.BoundedMailbox$ (implements java.io.Serializable)
- org.apache.pekko.dispatch.BoundedPriorityMailbox (implements org.apache.pekko.dispatch.MailboxType, org.apache.pekko.dispatch.ProducesMessageQueue<T>, org.apache.pekko.dispatch.ProducesPushTimeoutSemanticsMailbox)
- org.apache.pekko.dispatch.BoundedPriorityMailbox$
- org.apache.pekko.dispatch.BoundedStablePriorityMailbox (implements org.apache.pekko.dispatch.MailboxType, org.apache.pekko.dispatch.ProducesMessageQueue<T>, org.apache.pekko.dispatch.ProducesPushTimeoutSemanticsMailbox)
- org.apache.pekko.dispatch.BoundedStablePriorityMailbox$
- org.apache.pekko.dispatch.CachingConfig$
- org.apache.pekko.dispatch.Dispatchers
- org.apache.pekko.dispatch.Dispatchers$
- org.apache.pekko.dispatch.Envelope (implements scala.Product, java.io.Serializable)
- org.apache.pekko.dispatch.Envelope$ (implements java.io.Serializable)
- org.apache.pekko.dispatch.ExecutionContexts
- org.apache.pekko.dispatch.ExecutionContexts.sameThreadExecutionContext$ (implements org.apache.pekko.dispatch.BatchingExecutor, scala.concurrent.ExecutionContext)
- org.apache.pekko.dispatch.ExecutionContexts$
- org.apache.pekko.dispatch.ExecutorServiceConfigurator (implements org.apache.pekko.dispatch.ExecutorServiceFactoryProvider)
- org.apache.pekko.dispatch.DefaultExecutorServiceConfigurator
- org.apache.pekko.dispatch.ForkJoinExecutorConfigurator
- org.apache.pekko.dispatch.ThreadPoolExecutorConfigurator
- org.apache.pekko.dispatch.Filter
- org.apache.pekko.dispatch.Filter$
- org.apache.pekko.dispatch.ForkJoinExecutorConfigurator.ForkJoinExecutorServiceFactory (implements org.apache.pekko.dispatch.ExecutorServiceFactory)
- org.apache.pekko.dispatch.ForkJoinExecutorConfigurator$
- java.util.concurrent.ForkJoinTask<V> (implements java.util.concurrent.Future<V>, java.io.Serializable)
- org.apache.pekko.dispatch.ForkJoinExecutorConfigurator.PekkoForkJoinTask
- org.apache.pekko.dispatch.Futures
- org.apache.pekko.dispatch.Futures$
- org.apache.pekko.dispatch.japi
- org.apache.pekko.dispatch.japi.BooleanFunctionBridge<T> (implements scala.Function1<T1,R>)
- org.apache.pekko.dispatch.japi.UnitFunctionBridge<T> (implements scala.Function1<T1,R>)
- org.apache.pekko.dispatch.Foreach<T>
- org.apache.pekko.dispatch.japi$
- org.apache.pekko.dispatch.Mailbox$ (implements java.io.Serializable)
- org.apache.pekko.dispatch.Mailboxes$
- org.apache.pekko.dispatch.MessageDispatcher (implements org.apache.pekko.dispatch.BatchingExecutor, scala.concurrent.ExecutionContextExecutor)
- org.apache.pekko.dispatch.Dispatcher
- org.apache.pekko.dispatch.PinnedDispatcher
- org.apache.pekko.dispatch.Dispatcher
- org.apache.pekko.dispatch.MessageDispatcher$
- org.apache.pekko.dispatch.MessageDispatcherConfigurator
- org.apache.pekko.dispatch.BalancingDispatcherConfigurator
- org.apache.pekko.dispatch.DispatcherConfigurator
- org.apache.pekko.dispatch.PinnedDispatcherConfigurator
- org.apache.pekko.dispatch.MonitorableThreadFactory (implements java.util.concurrent.ForkJoinPool.ForkJoinWorkerThreadFactory, scala.Product, java.io.Serializable, java.util.concurrent.ThreadFactory)
- org.apache.pekko.dispatch.MonitorableThreadFactory$ (implements java.io.Serializable)
- org.apache.pekko.dispatch.NonBlockingBoundedMailbox (implements org.apache.pekko.dispatch.MailboxType, org.apache.pekko.dispatch.ProducesMessageQueue<T>, scala.Product, java.io.Serializable)
- org.apache.pekko.dispatch.PriorityGenerator (implements java.util.Comparator<T>)
- org.apache.pekko.dispatch.PriorityGenerator$
- org.apache.pekko.dispatch.SaneRejectedExecutionHandler (implements java.util.concurrent.RejectedExecutionHandler)
- org.apache.pekko.dispatch.SingleConsumerOnlyUnboundedMailbox (implements org.apache.pekko.dispatch.MailboxType, org.apache.pekko.dispatch.ProducesMessageQueue<T>, scala.Product, java.io.Serializable)
- org.apache.pekko.dispatch.TaskInvocation (implements org.apache.pekko.dispatch.Batchable, scala.Product, java.io.Serializable)
- org.apache.pekko.dispatch.ThreadPoolConfig (implements org.apache.pekko.dispatch.ExecutorServiceFactoryProvider, scala.Product, java.io.Serializable)
- org.apache.pekko.dispatch.ThreadPoolConfig.ThreadPoolExecutorServiceFactory (implements org.apache.pekko.dispatch.ExecutorServiceFactory)
- org.apache.pekko.dispatch.ThreadPoolConfig$ (implements java.io.Serializable)
- org.apache.pekko.dispatch.ThreadPoolConfigBuilder (implements scala.Product, java.io.Serializable)
- org.apache.pekko.dispatch.UnboundedControlAwareMailbox (implements org.apache.pekko.dispatch.MailboxType, org.apache.pekko.dispatch.ProducesMessageQueue<T>, scala.Product, java.io.Serializable)
- org.apache.pekko.dispatch.UnboundedControlAwareMailbox.MessageQueue (implements java.io.Serializable, org.apache.pekko.dispatch.UnboundedControlAwareMessageQueueSemantics)
- org.apache.pekko.dispatch.UnboundedControlAwareMailbox$ (implements java.io.Serializable)
- org.apache.pekko.dispatch.UnboundedDequeBasedMailbox (implements org.apache.pekko.dispatch.MailboxType, org.apache.pekko.dispatch.ProducesMessageQueue<T>, scala.Product, java.io.Serializable)
- org.apache.pekko.dispatch.UnboundedDequeBasedMailbox$ (implements java.io.Serializable)
- org.apache.pekko.dispatch.UnboundedMailbox (implements org.apache.pekko.dispatch.MailboxType, org.apache.pekko.dispatch.ProducesMessageQueue<T>, scala.Product, java.io.Serializable)
- org.apache.pekko.dispatch.UnboundedMailbox$ (implements java.io.Serializable)
- org.apache.pekko.dispatch.UnboundedPriorityMailbox (implements org.apache.pekko.dispatch.MailboxType, org.apache.pekko.dispatch.ProducesMessageQueue<T>)
- org.apache.pekko.dispatch.UnboundedPriorityMailbox$
- org.apache.pekko.dispatch.UnboundedStablePriorityMailbox (implements org.apache.pekko.dispatch.MailboxType, org.apache.pekko.dispatch.ProducesMessageQueue<T>)
- org.apache.pekko.dispatch.UnboundedStablePriorityMailbox$
- org.apache.pekko.dispatch.AbstractBoundedNodeQueue<T>
Interface Hierarchy
- org.apache.pekko.dispatch.BoundedMessageQueueSemantics
- org.apache.pekko.dispatch.BoundedControlAwareMessageQueueSemantics (also extends org.apache.pekko.dispatch.ControlAwareMessageQueueSemantics)
- org.apache.pekko.dispatch.BoundedDequeBasedMessageQueueSemantics (also extends org.apache.pekko.dispatch.DequeBasedMessageQueueSemantics)
- org.apache.pekko.dispatch.BoundedDequeBasedMessageQueue (also extends org.apache.pekko.dispatch.DequeBasedMessageQueue)
- org.apache.pekko.dispatch.BoundedQueueBasedMessageQueue (also extends org.apache.pekko.dispatch.QueueBasedMessageQueue)
- org.apache.pekko.dispatch.ControlMessage
- org.apache.pekko.dispatch.DefaultSystemMessageQueue
- org.apache.pekko.dispatch.DequeBasedMessageQueueSemantics
- org.apache.pekko.dispatch.BoundedDequeBasedMessageQueueSemantics (also extends org.apache.pekko.dispatch.BoundedMessageQueueSemantics)
- org.apache.pekko.dispatch.BoundedDequeBasedMessageQueue (also extends org.apache.pekko.dispatch.DequeBasedMessageQueue)
- org.apache.pekko.dispatch.DequeBasedMessageQueue (also extends org.apache.pekko.dispatch.QueueBasedMessageQueue)
- org.apache.pekko.dispatch.BoundedDequeBasedMessageQueue (also extends org.apache.pekko.dispatch.BoundedDequeBasedMessageQueueSemantics)
- org.apache.pekko.dispatch.UnboundedDequeBasedMessageQueue (also extends org.apache.pekko.dispatch.UnboundedDequeBasedMessageQueueSemantics)
- org.apache.pekko.dispatch.UnboundedDequeBasedMessageQueueSemantics (also extends org.apache.pekko.dispatch.UnboundedMessageQueueSemantics)
- org.apache.pekko.dispatch.UnboundedDequeBasedMessageQueue (also extends org.apache.pekko.dispatch.DequeBasedMessageQueue)
- org.apache.pekko.dispatch.BoundedDequeBasedMessageQueueSemantics (also extends org.apache.pekko.dispatch.BoundedMessageQueueSemantics)
- org.apache.pekko.dispatch.DispatcherPrerequisites
- java.util.concurrent.Executor
- org.apache.pekko.dispatch.BatchingExecutor
- java.util.concurrent.ExecutorService
- org.apache.pekko.dispatch.ExecutorServiceDelegate
- org.apache.pekko.dispatch.ExecutorServiceFactory
- org.apache.pekko.dispatch.ExecutorServiceFactoryProvider
- org.apache.pekko.dispatch.LoadMetrics
- org.apache.pekko.dispatch.MailboxType
- org.apache.pekko.dispatch.MessageQueue
- org.apache.pekko.dispatch.QueueBasedMessageQueue (also extends org.apache.pekko.dispatch.MultipleConsumerSemantics)
- org.apache.pekko.dispatch.BoundedQueueBasedMessageQueue (also extends org.apache.pekko.dispatch.BoundedMessageQueueSemantics)
- org.apache.pekko.dispatch.ControlAwareMessageQueueSemantics
- org.apache.pekko.dispatch.BoundedControlAwareMessageQueueSemantics (also extends org.apache.pekko.dispatch.BoundedMessageQueueSemantics)
- org.apache.pekko.dispatch.UnboundedControlAwareMessageQueueSemantics (also extends org.apache.pekko.dispatch.UnboundedMessageQueueSemantics)
- org.apache.pekko.dispatch.DequeBasedMessageQueue (also extends org.apache.pekko.dispatch.DequeBasedMessageQueueSemantics)
- org.apache.pekko.dispatch.BoundedDequeBasedMessageQueue (also extends org.apache.pekko.dispatch.BoundedDequeBasedMessageQueueSemantics)
- org.apache.pekko.dispatch.UnboundedDequeBasedMessageQueue (also extends org.apache.pekko.dispatch.UnboundedDequeBasedMessageQueueSemantics)
- org.apache.pekko.dispatch.UnboundedQueueBasedMessageQueue (also extends org.apache.pekko.dispatch.UnboundedMessageQueueSemantics)
- org.apache.pekko.dispatch.QueueBasedMessageQueue (also extends org.apache.pekko.dispatch.MultipleConsumerSemantics)
- org.apache.pekko.dispatch.MultipleConsumerSemantics
- org.apache.pekko.dispatch.QueueBasedMessageQueue (also extends org.apache.pekko.dispatch.MessageQueue)
- org.apache.pekko.dispatch.BoundedQueueBasedMessageQueue (also extends org.apache.pekko.dispatch.BoundedMessageQueueSemantics)
- org.apache.pekko.dispatch.ControlAwareMessageQueueSemantics
- org.apache.pekko.dispatch.BoundedControlAwareMessageQueueSemantics (also extends org.apache.pekko.dispatch.BoundedMessageQueueSemantics)
- org.apache.pekko.dispatch.UnboundedControlAwareMessageQueueSemantics (also extends org.apache.pekko.dispatch.UnboundedMessageQueueSemantics)
- org.apache.pekko.dispatch.DequeBasedMessageQueue (also extends org.apache.pekko.dispatch.DequeBasedMessageQueueSemantics)
- org.apache.pekko.dispatch.BoundedDequeBasedMessageQueue (also extends org.apache.pekko.dispatch.BoundedDequeBasedMessageQueueSemantics)
- org.apache.pekko.dispatch.UnboundedDequeBasedMessageQueue (also extends org.apache.pekko.dispatch.UnboundedDequeBasedMessageQueueSemantics)
- org.apache.pekko.dispatch.UnboundedQueueBasedMessageQueue (also extends org.apache.pekko.dispatch.UnboundedMessageQueueSemantics)
- org.apache.pekko.dispatch.QueueBasedMessageQueue (also extends org.apache.pekko.dispatch.MessageQueue)
- org.apache.pekko.dispatch.ProducesMessageQueue<T>
- org.apache.pekko.dispatch.ProducesPushTimeoutSemanticsMailbox
- org.apache.pekko.dispatch.RequiresMessageQueue<T>
- java.lang.Runnable
- org.apache.pekko.dispatch.Batchable
- org.apache.pekko.dispatch.SystemMessageQueue
- org.apache.pekko.dispatch.UnboundedMessageQueueSemantics
- org.apache.pekko.dispatch.UnboundedControlAwareMessageQueueSemantics (also extends org.apache.pekko.dispatch.ControlAwareMessageQueueSemantics)
- org.apache.pekko.dispatch.UnboundedDequeBasedMessageQueueSemantics (also extends org.apache.pekko.dispatch.DequeBasedMessageQueueSemantics)
- org.apache.pekko.dispatch.UnboundedDequeBasedMessageQueue (also extends org.apache.pekko.dispatch.DequeBasedMessageQueue)
- org.apache.pekko.dispatch.UnboundedQueueBasedMessageQueue (also extends org.apache.pekko.dispatch.QueueBasedMessageQueue)