Name | Description | Type | Package | Framework |
AbstractFuture | | Class | co.paralleluniverse.strands | Quasar |
|
AbstractOwnableSynchronizer | A synchronizer that may be exclusively owned by a strand. | Class | co.paralleluniverse.strands.concurrent | Quasar |
|
AbstractQueuedLongSynchronizer | A version of AbstractQueuedSynchronizer in which synchronization state is maintained as a long. | Class | co.paralleluniverse.strands.concurrent | Quasar |
|
AbstractQueuedSynchronizer | Provides a framework for implementing blocking locks and related synchronizers (semaphores, events, etc) that rely on | Class | co.paralleluniverse.strands.concurrent | Quasar |
|
AbstractRecord | An abstract implementation of Record. | Class | co.paralleluniverse.data.record | Quasar |
|
AbstractServerHandler | A convenience class implementing the ServerHandler interface. | Class | co.paralleluniverse.actors.behaviors | Quasar |
|
Actor | An actor is a self-contained execution unit - an object running in its own strand and communicating with other actors via messages. | Class | co.paralleluniverse.actors | Quasar |
|
ActorBuilder | An object that can construct a new actorConstructs a new actor | Interface | co.paralleluniverse.actors | Quasar |
|
ActorImpl | | Class | co.paralleluniverse.actors | Quasar |
|
ActorInfo | Information about an actor returned by ActorsMXBean. | Class | co.paralleluniverse.actors | Quasar |
|
ActorLoader | Loads actor, and actor-related classes for hot code-swapping. | Class | co.paralleluniverse.actors | Quasar |
|
ActorLoaderMXBean | | Interface | co.paralleluniverse.actors | Quasar |
|
ActorMessage | A class extended by all standard actor messages in this package. | Class | co.paralleluniverse.actors.behaviors | Quasar |
|
ActorMXBean | An MXBean monitoring a single actor. | Interface | co.paralleluniverse.actors | Quasar |
|
ActorRef | An actor's external API (for use by code not part of the actor). | Class | co.paralleluniverse.actors | Quasar |
|
ActorRefDelegate | An ActorRef which delegates all operations to another ActorRef. | Class | co.paralleluniverse.actors | Quasar |
|
ActorRegistry | A registry used to find registered actors by name. | Class | co.paralleluniverse.actors | Quasar |
|
ActorsMXBean | An MXBean that monitors all actors. | Interface | co.paralleluniverse.actors | Quasar |
|
ActorSpec | | Class | co.paralleluniverse.actors | Quasar |
|
ActorUtil | Static utility methods for working with actors. | Class | co.paralleluniverse.actors | Quasar |
|
AsyncCompletionStage | Turns CompletableFutures into fiber-blocking operations. | Class | co.paralleluniverse.fibers.futures | Quasar |
|
AsyncListenableFuture | Turns Google Guava's ListenableFutures into a fiber-blocking operation. | Class | co.paralleluniverse.fibers.futures | Quasar |
|
BasicActor | A subclass of Actor that provides selective receive capabilities. | Class | co.paralleluniverse.actors | Quasar |
|
Behavior | A general behavior-actor interfaceSee Also:Serialized Form | Class | co.paralleluniverse.actors.behaviors | Quasar |
|
BehaviorActor | A general behavior-actor class, extended by all behaviors. | Class | co.paralleluniverse.actors.behaviors | Quasar |
|
Channel | A message-passing channel. | Interface | co.paralleluniverse.strands.channels | Quasar |
|
ChannelClosedException | | Class | co.paralleluniverse.strands.channels | Quasar |
|
ChannelGroup | A grouping of channels for the purpose of resource sharing. | Class | co.paralleluniverse.fibers.io | Quasar |
|
Channels | A utility class for creating and manipulating channels. | Class | co.paralleluniverse.strands.channels | Quasar |
|
CheckedSuspendableCallable | This interface can represent any operation that may suspend the currently executing Strand (i. | Interface | co.paralleluniverse.strands | Quasar |
|
ConcurrencyException | | Class | co.paralleluniverse.actors | Quasar |
|
Condition | | Interface | co.paralleluniverse.strands | Quasar |
|
ConditionSelector | | Class | co.paralleluniverse.strands | Quasar |
|
ConditionSynchronizer | | Class | co.paralleluniverse.strands | Quasar |
|
CountDownLatch | A synchronization aid that allows one or more threads to wait until a set of operations being performed in other threads completes. | Class | co.paralleluniverse.strands.concurrent | Quasar |
|
CyclicBarrier | A synchronization aid that allows a set of threads to all wait for each other to reach a common barrier point. | Class | co.paralleluniverse.strands.concurrent | Quasar |
|
DefaultFiberScheduler | The default FiberScheduler used to schedule fibers that do not specify a particular scheduler. | Class | co.paralleluniverse.fibers | Quasar |
|
DelegatingReceivePort | | Class | co.paralleluniverse.strands.channels | Quasar |
|
DelegatingSendPort | | Class | co.paralleluniverse.strands.channels | Quasar |
|
DoneSynchronizer | | Class | co.paralleluniverse.strands | Quasar |
|
DoubleChannel | A channel for primitive double messages. | Interface | co.paralleluniverse.strands.channels | Quasar |
|
DoubleReceivePort | A primitive double channel's consumer-side interface. | Interface | co.paralleluniverse.strands.channels | Quasar |
|
DoubleSendPort | A primitive double channel's producer-side interface. | Interface | co.paralleluniverse.strands.channels | Quasar |
|
ErrorMessage | | Interface | co.paralleluniverse.actors.behaviors | Quasar |
|
ErrorResponseMessage | A simple subclass of ResponseMessage that represents an error in processing the request. | Class | co.paralleluniverse.actors.behaviors | Quasar |
|
EventHandler | | Interface | co.paralleluniverse.actors.behaviors | Quasar |
|
EventSource | An interface to an EventSourceActor. | Class | co.paralleluniverse.actors.behaviors | Quasar |
|
EventSourceActor | A behavior actor that can be notified of *event* messages, which are delivered to *event handlers* which may be registered with the actor. | Class | co.paralleluniverse.actors.behaviors | Quasar |
|
ExitMessage | A LifecycleMessage signifying an actor's death. | Class | co.paralleluniverse.actors | Quasar |
|
FakeActor | An ActorRef which is not backed by any actual Actor. | Class | co.paralleluniverse.actors | Quasar |
|
Fiber | A lightweight thread. | Class | co.paralleluniverse.fibers | Quasar |
|
FiberAsync | A general helper class that transforms asynchronous requests to synchronous (fiber-blocking) calls. | Class | co.paralleluniverse.fibers | Quasar |
|
FiberExecutorScheduler | A fiber scheduler that uses a given Executor for scheduling. | Class | co.paralleluniverse.fibers | Quasar |
|
FiberFactory | Creates new fibers on demand. | Interface | co.paralleluniverse.fibers | Quasar |
|
FiberFileChannel | A fiber-blocking version of FileChannel. | Class | co.paralleluniverse.fibers.io | Quasar |
|
FiberForkJoinScheduler | A ForkJoinPool based scheduler for fibers. | Class | co.paralleluniverse.fibers | Quasar |
|
FiberInfo | Current information about a fiber returned by FibersMXBean. | Class | co.paralleluniverse.fibers | Quasar |
|
FiberScheduler | A thread-pool based scheduler for fibers. | Class | co.paralleluniverse.fibers | Quasar |
|
FiberServerSocketChannel | A fiber-blocking version of ServerSocketChannel. | Class | co.paralleluniverse.fibers.io | Quasar |
|
FibersMXBean | An MXBean that monitors fibers scheduled by a single FiberScheduler. | Interface | co.paralleluniverse.fibers | Quasar |
|
FiberSocketChannel | A fiber-blocking version of SocketChannel. | Class | co.paralleluniverse.fibers.io | Quasar |
|
FiberUtil | Static utility methods for working with fibers. | Class | co.paralleluniverse.fibers | Quasar |
|
FiberWriter | A callback used by Fiber. | Interface | co.paralleluniverse.fibers | Quasar |
|
Field | | Class | co.paralleluniverse.data.record | Quasar |
|
FieldNotFoundException | Thrown by a Record when trying to get or set a field that is not in the record. | Class | co.paralleluniverse.data.record | Quasar |
|
FiniteStateMachineActor | A behavior implementing a finite-state-machine. | Class | co.paralleluniverse.actors.behaviors | Quasar |
|
FlatMappingReceivePort | | Class | co.paralleluniverse.strands.channels | Quasar |
|
FloatChannel | A channel for primitive float messages. | Interface | co.paralleluniverse.strands.channels | Quasar |
|
FloatReceivePort | A primitive float channel's consumer-side interface. | Interface | co.paralleluniverse.strands.channels | Quasar |
|
FloatSendPort | A primitive float channel's producer-side interface. | Interface | co.paralleluniverse.strands.channels | Quasar |
|
FromMessage | An actor message that identifies its senderThe actor that sent the message. | Interface | co.paralleluniverse.actors.behaviors | Quasar |
|
IdMessage | An actor message with a unique (or unique with a high probability) ID (usually generated by ActorUtil. | Interface | co.paralleluniverse.actors.behaviors | Quasar |
|
Initializer | A delegate object that can be used instead of subclassing BehaviorActor and overriding its methods. | Interface | co.paralleluniverse.actors.behaviors | Quasar |
|
IntChannel | A channel for primitive int messages. | Interface | co.paralleluniverse.strands.channels | Quasar |
|
IntReceivePort | A primitive int channel's consumer-side interface. | Interface | co.paralleluniverse.strands.channels | Quasar |
|
IntSendPort | A primitive int channel's producer-side interface. | Interface | co.paralleluniverse.strands.channels | Quasar |
|
Joinable | | Interface | co.paralleluniverse.fibers | Quasar |
|
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. | Class | co.paralleluniverse.actors | Quasar |
|
LifecycleMessage | | Interface | co.paralleluniverse.actors | Quasar |
|
LocalActor | Static methods that provide access to Actor's functionality through an ActorRef if the actor is local. | Class | co.paralleluniverse.actors | Quasar |
|
LongChannel | A channel for primitive double messages. | Interface | co.paralleluniverse.strands.channels | Quasar |
|
LongReceivePort | A primitive long channel's consumer-side interface. | Interface | co.paralleluniverse.strands.channels | Quasar |
|
LongSendPort | A primitive long channel's producer-side interface. | Interface | co.paralleluniverse.strands.channels | Quasar |
|
Mailbox | A channel that is used as an actor's mailbox. | Class | co.paralleluniverse.actors | Quasar |
|
MailboxConfig | An actor mailbox configuration. | Class | co.paralleluniverse.actors | Quasar |
|
MessageProcessor | An interface that is used by BasicActor. | Interface | co.paralleluniverse.actors | Quasar |
|
MessageSelector | A fluent interface for creating MessageProcessors that select messages matching a few simple criteria. | Class | co.paralleluniverse.actors.behaviors | Quasar |
|
MigratingActor | | Interface | co.paralleluniverse.actors | Quasar |
|
Mix | ReceivePort with Mix operations. | Interface | co.paralleluniverse.strands.channels | Quasar |
|
OnUpgrade | | Class | co.paralleluniverse.actors | Quasar |
|
OwnedSynchronizer | | Class | co.paralleluniverse.strands | Quasar |
|
Phaser | A reusable synchronization barrier, similar in functionality to but supporting more flexible usage. | Class | co.paralleluniverse.strands.concurrent | Quasar |
|
Pipeline | | Class | co.paralleluniverse.strands.channels.transfer | Quasar |
|
Port | | Interface | co.paralleluniverse.strands.channels | Quasar |
|
PortAutoCloseable | Closes the channel so that no more messages could be sent to it. | Interface | co.paralleluniverse.strands.channels | Quasar |
|
ProducerException | This exception is thrown by a ReceivePort's receive or tryReceive methods if the channel has been closed with an exception. | Class | co.paralleluniverse.strands.channels | Quasar |
|
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). | Class | co.paralleluniverse.actors.behaviors | Quasar |
|
QueueChannel | | Class | co.paralleluniverse.strands.channels | Quasar |
|
QueueDoubleChannel | | Class | co.paralleluniverse.strands.channels | Quasar |
|
QueueFloatChannel | | Class | co.paralleluniverse.strands.channels | Quasar |
|
QueueIntChannel | | Class | co.paralleluniverse.strands.channels | Quasar |
|
QueueLongChannel | | Class | co.paralleluniverse.strands.channels | Quasar |
|
QueueObjectChannel | | Class | co.paralleluniverse.strands.channels | Quasar |
|
QueuePrimitiveChannel | | Class | co.paralleluniverse.strands.channels | Quasar |
|
ReactiveStreams | | Class | co.paralleluniverse.strands.channels.reactivestreams | Quasar |
|
ReadOnlyFieldException | Thrown by a Record when trying to set a field that is read-only. | Class | co.paralleluniverse.data.record | Quasar |
|
ReceivePort | A channel's consumer-side functional interface. | Interface | co.paralleluniverse.strands.channels | Quasar |
|
ReceivePortGroup | | Class | co.paralleluniverse.strands.channels | Quasar |
|
Record | A record made of some Fields with values. | Interface | co.paralleluniverse.data.record | Quasar |
|
RecordArray | Represents an array of Records. | Interface | co.paralleluniverse.data.record | Quasar |
|
RecordException | | Class | co.paralleluniverse.data.record | Quasar |
|
Records | Static utility methods for working with records. | Class | co.paralleluniverse.data.record | Quasar |
|
RecordType | Represents a record type, and includes a name, and a list of fields along with their names and types. | Class | co.paralleluniverse.data.record | Quasar |
|
ReentrantLock | A reentrant mutual exclusion Lock with the same basic behavior and semantics as the implicit monitor lock accessed using | Class | co.paralleluniverse.strands.concurrent | Quasar |
|
ReentrantReadWriteLock | An implementation of ReadWriteLock supporting similar semantics to ReentrantLock. | Class | co.paralleluniverse.strands.concurrent | Quasar |
|
RegistrationException | | Class | co.paralleluniverse.actors | Quasar |
|
RemoteActor | This class should be extended by implementations of remote actors. | Class | co.paralleluniverse.actors | Quasar |
|
RequestMessage | 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. | Class | co.paralleluniverse.actors.behaviors | Quasar |
|
RequestReplyHelper | This class contains static methods that implement a request-reply pattern with actors. | Class | co.paralleluniverse.actors.behaviors | Quasar |
|
ResponseMessage | A message type used as a superclass by responses to RequestMessage. | Class | co.paralleluniverse.actors.behaviors | Quasar |
|
RuntimeExecutionException | Similar to ExecutionException only as an unchecked, rather than a checked, exception. | Class | co.paralleluniverse.fibers | Quasar |
|
RuntimeSuspendExecution | | Class | co.paralleluniverse.fibers | Quasar |
|
SchedulerLocal | | Class | co.paralleluniverse.fibers | Quasar |
|
SealedRecordType | | Interface | co.paralleluniverse.data.record | Quasar |
|
Selectable | A channel port that can be used by a Selector. | Interface | co.paralleluniverse.strands.channels | Quasar |
|
SelectAction | A channel operation that is selected by a Selector. | Class | co.paralleluniverse.strands.channels | Quasar |
|
SelectiveReceiveHelper | Performs selective receive on behalf of an actor. | Class | co.paralleluniverse.actors | Quasar |
|
Selector | Attempts to perform at most one channel operation (send or receive) of a given set. | Class | co.paralleluniverse.strands.channels | Quasar |
|
SelectReceiveListener | A listener associated with a receive SelectAction, which is called if an only if the associated action has succeeded. | Interface | co.paralleluniverse.strands.channels | Quasar |
|
SelectSendListener | A listener associated with a send SelectAction, which is called if an only if the associated action has succeeded. | Interface | co.paralleluniverse.strands.channels | Quasar |
|
Semaphore | A counting semaphore. | Class | co.paralleluniverse.strands.concurrent | Quasar |
|
SendPort | A channel's producer-side functional interface. | Interface | co.paralleluniverse.strands.channels | Quasar |
|
Server | An interface to a ServerActor. | Class | co.paralleluniverse.actors.behaviors | Quasar |
|
ServerActor | A behavior implementing a server that responds to request messages. | Class | co.paralleluniverse.actors.behaviors | Quasar |
|
ServerHandler | A delegate object that can be used instead of subclassing ServerActor and overriding its methods. | Interface | co.paralleluniverse.actors.behaviors | Quasar |
|
SettableFuture | | Class | co.paralleluniverse.strands | Quasar |
|
ShutdownMessage | A message requesting the receiving actor to shut itself down. | Class | co.paralleluniverse.actors | Quasar |
|
SimpleConditionSynchronizer | | Class | co.paralleluniverse.strands | Quasar |
|
SingleConsumerQueueChannel | | Class | co.paralleluniverse.strands.channels | Quasar |
|
SplitSendPort | SendPort that will send messages it receives to a target SendPort. | Class | co.paralleluniverse.strands.channels | Quasar |
|
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 | Class | co.paralleluniverse.fibers | Quasar |
|
StampedLock | A capability-based lock with three modes for controlling read/write access. | Class | co.paralleluniverse.strands.concurrent | Quasar |
|
StandardChannel | | Interface | co.paralleluniverse.strands.channels | Quasar |
|
Strand | | Class | co.paralleluniverse.strands | Quasar |
|
Stranded | | Interface | co.paralleluniverse.strands | Quasar |
|
StrandFactory | Creates new strnads on demand. | Interface | co.paralleluniverse.strands | Quasar |
|
StrandFactoryBuilder | Easily creates StrandFactorys. | Class | co.paralleluniverse.strands | Quasar |
|
StrandLocalRandom | A random number generator isolated to the current thread. | Class | co.paralleluniverse.strands | Quasar |
|
Supervisor | An interface to a SupervisorActor. | Class | co.paralleluniverse.actors.behaviors | Quasar |
|
SupervisorActor | An actor that supervises, and if necessary, restarts other actors. | Class | co.paralleluniverse.actors.behaviors | Quasar |
|
SupervisorException | | Class | co.paralleluniverse.actors.behaviors | Quasar |
|
Suspendable | Marks a method as suspendable. | Class | co.paralleluniverse.fibers | Quasar |
|
SuspendableAction1 | throws SuspendExecution, InterruptedException | Interface | co.paralleluniverse.strands | Quasar |
|
SuspendableAction2 | throws SuspendExecution, InterruptedException | Interface | co.paralleluniverse.strands | Quasar |
|
SuspendableCallable | This interface can represent any operation that may suspend the currently executing Strand (i. | Interface | co.paralleluniverse.strands | Quasar |
|
SuspendableRunnable | This interface can represent any operation that may suspend the currently executing Strand (i. | Interface | co.paralleluniverse.strands | Quasar |
|
SuspendableUtils | | Class | co.paralleluniverse.strands | Quasar |
|
SuspendExecution | An exception used to initiate the control transfer. | Class | co.paralleluniverse.fibers | Quasar |
|
Synchronization | | Interface | co.paralleluniverse.strands | Quasar |
|
ThreadLocalSerializer | | Class | co.paralleluniverse.fibers | Quasar |
|
ThreadReceivePort | This class is a simple convenience wrapper around ReceivePort that can be used by threads (as opposed to fibers). | Class | co.paralleluniverse.strands.channels | Quasar |
|
ThreadSendPort | This class is a simple convenience wrapper around SendPort that can be used by threads (as opposed to fibers). | Class | co.paralleluniverse.strands.channels | Quasar |
|
TickerChannelConsumer | A ReceivePort which is a view of a ticker channel. | Class | co.paralleluniverse.strands.channels | Quasar |
|
Timeout | Represents a timeout that can span several operations. | Class | co.paralleluniverse.strands | Quasar |
|
TimeoutChannel | | Class | co.paralleluniverse.strands.channels | Quasar |
|
Topic | A channel that forwards all messages to subscriber channels. | Class | co.paralleluniverse.strands.channels | Quasar |
|
TransferChannel | | Class | co.paralleluniverse.strands.channels | Quasar |
|
TransformingReceivePort | A ReceivePort with additional functional-transform operations, usually wrapping a plain ReceivePort. | Class | co.paralleluniverse.strands.channels | Quasar |
|
TransformingSendPort | A SendPort with additional functional-transform operations, usually wrapping a plain SendPort. | Class | co.paralleluniverse.strands.channels | Quasar |
|
TrueThreadLocal | A ThreadLocal that is local to the current thread, rather than Strand. | Class | co.paralleluniverse.fibers | Quasar |
|
Upgrade | | Class | co.paralleluniverse.actors | Quasar |
|
Val | A dataflow constant. | Class | co.paralleluniverse.strands.dataflow | Quasar |
|
ValChannel | An adapter that turns a DelayedVal into a ReceivePort that receives the DelayedVal's value and then closes. | Class | co.paralleluniverse.strands.dataflow | Quasar |
|
ValueResponseMessage | A simple subclass of ResponseMessage that encapsulates a single response value. | Class | co.paralleluniverse.actors.behaviors | Quasar |
|
Var | A dataflow variable. | Class | co.paralleluniverse.strands.dataflow | Quasar |
|
VerifyInstrumentationException | | Class | co.paralleluniverse.fibers | Quasar |
|
ZippingReceivePort | | Class | co.paralleluniverse.strands.channels | Quasar |