All Classes

Class	Description
AbstractFuture<V>
AbstractOwnableSynchronizer	A synchronizer that may be exclusively owned by a strand.
AbstractQueuedLongSynchronizer	A version of AbstractQueuedSynchronizer in which synchronization state is maintained as a long.
AbstractQueuedSynchronizer	Provides a framework for implementing blocking locks and related synchronizers (semaphores, events, etc) that rely on first-in-first-out (FIFO) wait queues.
AbstractServerHandler<CallMessage,V,CastMessage>	A convenience class implementing the ServerHandler interface.
Actor<Message,V>	An actor is a self-contained execution unit - an object running in its own strand and communicating with other actors via messages.
ActorBuilder<Message,V>	An object that can construct a new actor
ActorImpl<Message>
ActorImpl.ActorLifecycleListener
ActorInfo	Information about an actor returned by ActorsMXBean.
ActorLoader	Loads actor, and actor-related classes for hot code-swapping.
ActorLoaderMXBean
ActorMessage	A class extended by all standard actor messages in this package.
ActorMXBean	An MXBean monitoring a single actor.
ActorRef<Message>	An actor's external API (for use by code not part of the actor).
ActorRefDelegate<Message>	An ActorRef which delegates all operations to another ActorRef.
ActorRegistry	A registry used to find registered actors by name.
ActorsMXBean	An MXBean that monitors all actors.
ActorSpec<T extends Actor<Message,V>,Message,V>	A specification of how to construct an actor
ActorUtil	Static utility methods for working with actors.
AsyncCompletionStage<V>	Turns CompletableFutures into fiber-blocking operations.
AsyncListenableFuture<V>	Turns Google Guava's ListenableFutures into a fiber-blocking operation.
BasicActor<Message,V>	A subclass of Actor that provides selective receive capabilities.
Behavior	A general behavior-actor interface
BehaviorActor	A general behavior-actor class, extended by all behaviors.
Channel<Message>	A message-passing channel.
ChannelClosedException
ChannelGroup	A grouping of channels for the purpose of resource sharing.
Channels	A utility class for creating and manipulating channels.
Channels.OverflowPolicy	Determines how a channel behaves when its internal buffer (if it has one) overflows.
CheckedSuspendableCallable<V,E extends java.lang.Exception>	This interface can represent any operation that may suspend the currently executing Strand (i.e.
ConcurrencyException
Condition
ConditionSelector
ConditionSynchronizer
CountDownLatch	A synchronization aid that allows one or more threads to wait until a set of operations being performed in other threads completes.
CustomFiberWriter	A callback used by Fiber.parkAndCustomSerialize(CustomFiberWriter).
CustomFiberWriterSerializer
CyclicBarrier	A synchronization aid that allows a set of threads to all wait for each other to reach a common barrier point.
DefaultFiberScheduler	The default FiberScheduler used to schedule fibers that do not specify a particular scheduler.
DelegatingReceivePort<T>
DelegatingSendPort<T>
DoneSynchronizer
DoubleChannel	A channel for primitive double messages.
DoubleReceivePort	A primitive double channel's consumer-side interface.
DoubleSendPort	A primitive double channel's producer-side interface.
ErrorMessage	An actor message signifying some error
ErrorResponseMessage	A simple subclass of ResponseMessage that represents an error in processing the request.
EventHandler<Event>	A handler that can be registered with an EventSource actor to receive all events sent to the actor.
EventSource<Event>	An interface to an EventSourceActor.
EventSourceActor<Event>	A behavior actor that can be notified of *event* messages, which are delivered to *event handlers* which may be registered with the actor.
ExitMessage	A LifecycleMessage signifying an actor's death.
FakeActor<Message>	An ActorRef which is not backed by any actual Actor.
Fiber<V>	A lightweight thread.
FiberAsync<V,E extends java.lang.Throwable>	A general helper class that transforms asynchronous requests to synchronous (fiber-blocking) calls.
FiberControl
FiberExecutorScheduler	A fiber scheduler that uses a given Executor for scheduling.
FiberFactory	Creates new fibers on demand.
FiberFileChannel	A fiber-blocking version of FileChannel.
FiberForkJoinScheduler	A ForkJoinPool based scheduler for fibers.
FiberInfo	Current information about a fiber returned by FibersMXBean.
FiberScheduler	A thread-pool based scheduler for fibers.
FiberSchedulerTask	The Runnable tasks passed to a FiberExecutorScheduler's Executor implement this interface.
FiberServerSocketChannel	A fiber-blocking version of ServerSocketChannel.
FibersMXBean	An MXBean that monitors fibers scheduled by a single FiberScheduler.
FiberSocketChannel	A fiber-blocking version of SocketChannel.
FiberUtil	Static utility methods for working with fibers.
FiberWriter	A callback used by Fiber.parkAndSerialize..
FiniteStateMachineActor	A behavior implementing a finite-state-machine.
FlatMappingReceivePort<S,T>
FloatChannel	A channel for primitive float messages.
FloatReceivePort	A primitive float channel's consumer-side interface.
FloatSendPort	A primitive float channel's producer-side interface.
FromMessage	An actor message that identifies its sender
IdMessage	An actor message with a unique (or unique with a high probability) ID (usually generated by ActorUtil.randtag() or RequestReplyHelper.makeId()).
Initializer	A delegate object that can be used instead of subclassing BehaviorActor and overriding its methods.
IntChannel	A channel for primitive int messages.
IntReceivePort	A primitive int channel's consumer-side interface.
IntSendPort	A primitive int channel's producer-side interface.
Joinable<V>
LifecycleException	An exception that is generated by an actor's handleLifecycle method (and thrown by the receive method) if an ExitMessage is received from a linked actor.
LifecycleMessage	A message that is automatically generated by an actor upon some lifecycle event (like death) and sent to its watchers or linked actors.
LocalActor	Static methods that provide access to Actor's functionality through an ActorRef if the actor is local.
LongChannel	A channel for primitive double messages.
LongReceivePort	A primitive long channel's consumer-side interface.
LongSendPort	A primitive long channel's producer-side interface.
Mailbox<Message>	A channel that is used as an actor's mailbox.
MailboxConfig	An actor mailbox configuration.
MessageProcessor<Message,T>	An interface that is used by BasicActor.receive for selective receive.
MessageSelector<M1,M2>	A fluent interface for creating MessageProcessors that select messages matching a few simple criteria.
MigratingActor	A marker interface that must be implemented by actors wishing to support migration
Mix<M>	ReceivePort with Mix operations.
Mix.Mode
Mix.SoloEffect
Mix.State
OnUpgrade	Specifies that a method is to be called after its class has been upgraded.
OwnedSynchronizer
Phaser	A reusable synchronization barrier, similar in functionality to CyclicBarrier and CountDownLatch but supporting more flexible usage.
Pipeline<S,T>
Port<Message>	An empty super-interface of SendPort and ReceivePort extend.
PortAutoCloseable
ProducerException	This exception is thrown by a ReceivePort's receive or tryReceive methods if the channel has been closed with an exception.
ProxyServerActor	Wraps a Java object in a ServerActor that exposes the object's methods as an interface and processes them in an actor (on a dedicated strand).
ProxyServerActor.Invocation
QueueChannel<Message>
QueueDoubleChannel
QueueFloatChannel
QueueIntChannel
QueueLongChannel
QueueObjectChannel<Message>
QueuePrimitiveChannel<Message>	Single consumer!
ReactiveStreams	Converts between Quasar channels and reactive streams
ReceivePort<Message>	A channel's consumer-side functional interface.
ReceivePort.EOFException
ReceivePortGroup<M>
ReentrantLock	A reentrant mutual exclusion Lock with the same basic behavior and semantics as the implicit monitor lock accessed using synchronized methods and statements, but with extended capabilities.
ReentrantReadWriteLock	An implementation of ReadWriteLock supporting similar semantics to ReentrantLock.
ReentrantReadWriteLock.ReadLock	The lock returned by method ReentrantReadWriteLock.readLock().
ReentrantReadWriteLock.WriteLock	The lock returned by method ReentrantReadWriteLock.writeLock().
RegistrationException
RemoteActor<Message>	This class should be extended by implementations of remote actors.
RemoteActor.RemoteActorAdminMessage
RequestMessage<V>	A message that contains a sender reference (the from property} and a unique identifier (the id property) and may be used as a request by RequestReplyHelper.call().
RequestReplyHelper	This class contains static methods that implement a request-reply pattern with actors.
ResponseMessage	A message type used as a superclass by responses to RequestMessage.
RuntimeExecutionException	Similar to ExecutionException only as an unchecked, rather than a checked, exception.
RuntimeSuspendExecution
SchedulerLocal<T>	Associates a value with the current FiberScheduler
Selectable<Message>	A channel port that can be used by a Selector.
SelectAction<Message>	A channel operation that is selected by a Selector.
SelectiveReceiveHelper<Message>	Performs selective receive on behalf of an actor.
Selector<Message>	Attempts to perform at most one channel operation (send or receive) of a given set.
SelectReceiveListener<Message>	A listener associated with a receive SelectAction, which is called if an only if the associated action has succeeded.
SelectSendListener<Message>	A listener associated with a send SelectAction, which is called if an only if the associated action has succeeded.
Semaphore	A counting semaphore.
SendPort<Message>	A channel's producer-side functional interface.
Server<CallMessage,V,CastMessage>	An interface to a ServerActor.
ServerActor<CallMessage,V,CastMessage>	A behavior implementing a server that responds to request messages.
ServerHandler<CallMessage,V,CastMessage>	A delegate object that can be used instead of subclassing ServerActor and overriding its methods.
SettableFuture<V>
ShutdownMessage	A message requesting the receiving actor to shut itself down.
SimpleConditionSynchronizer
SingleConsumerQueueChannel<Message>
SplitSendPort<Message>	SendPort that will send messages it receives to a target SendPort.
Stack	Internal Class - DO NOT USE! (Public so that instrumented code can access it) ANY CHANGE IN THIS CLASS NEEDS TO BE SYNCHRONIZED WITH InstrumentMethod
StampedLock	A capability-based lock with three modes for controlling read/write access.
StandardChannel<Message>	A common interface for standard channel implementations
Strand	A Strand is either a Thread or a Fiber
Strand.State	A strand's running state
Strand.UncaughtExceptionHandler	Interface for handlers invoked when a Strand abruptly terminates due to an uncaught exception.
Stranded
StrandFactory	Creates new strands on demand.
StrandFactoryBuilder	Easily creates StrandFactorys.
StrandLocalRandom	A random number generator isolated to the current thread.
Supervisor	An interface to a SupervisorActor.
Supervisor.ChildMode	Determines whether a child (supervised) actor should be restarted if the supervisor's restart strategy states that it should be restarted.
Supervisor.ChildSpec	Describes a child actor's configuration in a supervisor
SupervisorActor	An actor that supervises, and if necessary, restarts other actors.
SupervisorActor.RestartStrategy	Specifies a supervisor's strategy in the event a child dies.
SupervisorException
Suspendable	Marks a method as suspendable.
SuspendableAction1<S>
SuspendableAction2<S1,S2>
SuspendableCallable<V>	This interface can represent any operation that may suspend the currently executing Strand (i.e.
SuspendableRunnable	This interface can represent any operation that may suspend the currently executing Strand (i.e.
SuspendableUtils
SuspendableUtils.VoidSuspendableCallable
SuspendExecution	An exception used to initiate the control transfer.
Synchronization
ThreadLocalSerializer
ThreadReceivePort<Message>	This class is a simple convenience wrapper around ReceivePort that can be used by threads (as opposed to fibers).
ThreadSendPort<Message>	This class is a simple convenience wrapper around SendPort that can be used by threads (as opposed to fibers).
TickerChannelConsumer<Message>	A ReceivePort which is a view of a ticker channel.
TickerChannelConsumer.TickerChannelFloatConsumer
Timeout	Represents a timeout that can span several operations.
TimeoutChannel<Message>
Topic<Message>	A channel that forwards all messages to subscriber channels.
TransferChannel<Message>
TransformingReceivePort<T>	A ReceivePort with additional functional-transform operations, usually wrapping a plain ReceivePort.
TransformingSendPort<T>	A SendPort with additional functional-transform operations, usually wrapping a plain SendPort.
TrueThreadLocal<T>	A ThreadLocal that is local to the current thread, rather than Strand.
Upgrade	Marks an actor class as a code upgrade.
Val<V>	A dataflow constant.
ValChannel<V>	An adapter that turns a DelayedVal into a ReceivePort that receives the DelayedVal's value and then closes.
ValueResponseMessage<V>	A simple subclass of ResponseMessage that encapsulates a single response value.
Var<T>	A dataflow variable.
VerifyInstrumentationException
ZippingReceivePort<Message>	Single consumer