Serialized Form
-
Package co.paralleluniverse.actors
-
Class co.paralleluniverse.actors.Actor extends ActorImpl<Message> implements Serializable
-
Serialization Methods
-
readResolve
protected java.lang.Object readResolve() throws java.io.ObjectStreamException
- Throws:
java.io.ObjectStreamException
-
writeReplace
protected final java.lang.Object writeReplace() throws java.io.ObjectStreamException
- Throws:
java.io.ObjectStreamException
-
-
Serialized Fields
-
aux
java.lang.Object aux
-
deathCause
java.lang.Throwable deathCause
-
exception
java.lang.Throwable exception
-
forwardWatch
boolean forwardWatch
-
globalId
java.lang.Object globalId
-
hasMonitor
boolean hasMonitor
-
lifecycleListeners
java.util.Set<co.paralleluniverse.actors.LifecycleListener> lifecycleListeners
-
migrating
boolean migrating
-
observed
java.util.Set<ActorRef> observed
-
registered
boolean registered
-
result
V result
-
runner
co.paralleluniverse.actors.ActorRunner<V> runner
-
spec
ActorSpec<?,Message,V> spec
-
-
-
Class co.paralleluniverse.actors.ActorImpl extends java.lang.Object implements Serializable
- serialVersionUID:
- 894359345L
-
Serialized Fields
-
lifecycleListener
co.paralleluniverse.actors.LifecycleListener lifecycleListener
-
mailbox
SendPort<java.lang.Object> mailbox
-
name
java.lang.String name
-
-
Class co.paralleluniverse.actors.ActorImpl.ActorLifecycleListener extends java.lang.Object implements Serializable
-
Serialized Fields
-
id
java.lang.Object id
-
observer
ActorRef observer
-
-
-
Class co.paralleluniverse.actors.ActorRef extends java.lang.Object implements Serializable
-
Class co.paralleluniverse.actors.ActorRefDelegate extends ActorRef<Message> implements Serializable
-
Class co.paralleluniverse.actors.BasicActor extends Actor<Message,V> implements Serializable
-
Serialization Methods
-
readResolve
protected java.lang.Object readResolve() throws java.io.ObjectStreamException
- Throws:
java.io.ObjectStreamException
-
-
Serialized Fields
-
helper
SelectiveReceiveHelper<Message> helper
-
-
-
Class co.paralleluniverse.actors.ConcurrencyException extends java.lang.RuntimeException implements Serializable
-
Class co.paralleluniverse.actors.ExitMessage extends java.lang.Object implements Serializable
-
Serialized Fields
-
actor
ActorRef actor
-
cause
java.lang.Throwable cause
-
watch
java.lang.Object watch
-
-
-
Class co.paralleluniverse.actors.FakeActor extends ActorImpl<Message> implements Serializable
-
Serialization Methods
-
writeReplace
protected final java.lang.Object writeReplace() throws java.io.ObjectStreamException
- Throws:
java.io.ObjectStreamException
-
-
Serialized Fields
-
deathCause
java.lang.Throwable deathCause
-
lifecycleListeners
java.util.Set<co.paralleluniverse.actors.LifecycleListener> lifecycleListeners
-
observed
java.util.Set<ActorImpl> observed
-
-
-
Class co.paralleluniverse.actors.LifecycleException extends java.lang.RuntimeException implements Serializable
-
Serialized Fields
-
message
LifecycleMessage message
-
-
-
Class co.paralleluniverse.actors.Mailbox extends SingleConsumerQueueChannel<Message> implements Serializable
-
Serialization Methods
-
writeReplace
protected java.lang.Object writeReplace() throws java.io.ObjectStreamException
- Throws:
java.io.ObjectStreamException
-
-
Serialized Fields
-
config
MailboxConfig config
-
registrationToken
java.lang.Object registrationToken
-
-
-
Class co.paralleluniverse.actors.MailboxConfig extends java.lang.Object implements Serializable
-
Serialized Fields
-
mailboxSize
int mailboxSize
-
policy
Channels.OverflowPolicy policy
-
-
-
Class co.paralleluniverse.actors.RegistrationException extends java.lang.RuntimeException implements Serializable
-
Class co.paralleluniverse.actors.RemoteActor extends ActorImpl<Message> implements Serializable
-
Class co.paralleluniverse.actors.RemoteActor.RemoteActorAdminMessage extends java.lang.Object implements Serializable
-
Class co.paralleluniverse.actors.SelectiveReceiveHelper extends java.lang.Object implements Serializable
-
Serialized Fields
-
currentMessageIndex
int currentMessageIndex
-
-
-
Class co.paralleluniverse.actors.ShutdownMessage extends java.lang.Object implements Serializable
-
Serialized Fields
-
requester
ActorRef requester
-
-
-
-
Package co.paralleluniverse.actors.behaviors
-
Class co.paralleluniverse.actors.behaviors.ActorMessage extends java.lang.Object implements Serializable
-
Class co.paralleluniverse.actors.behaviors.Behavior extends ActorRefDelegate<java.lang.Object> implements Serializable
-
Class co.paralleluniverse.actors.behaviors.BehaviorActor extends Actor<java.lang.Object,java.lang.Void> implements Serializable
-
Serialized Fields
-
initializer
Initializer initializer
-
run
boolean run
-
-
-
Class co.paralleluniverse.actors.behaviors.ErrorResponseMessage extends ResponseMessage implements Serializable
-
Serialized Fields
-
error
java.lang.Throwable error
-
-
-
Class co.paralleluniverse.actors.behaviors.EventSource extends Behavior implements Serializable
-
Class co.paralleluniverse.actors.behaviors.EventSourceActor extends BehaviorActor implements Serializable
-
Serialized Fields
-
handlers
java.util.List<EventHandler<Event>> handlers
-
nonUpgradedHandlers
java.util.List<EventHandler<Event>> nonUpgradedHandlers
-
-
-
Class co.paralleluniverse.actors.behaviors.FiniteStateMachineActor extends BehaviorActor implements Serializable
-
Serialization Methods
-
readResolve
protected java.lang.Object readResolve() throws java.io.ObjectStreamException
- Throws:
java.io.ObjectStreamException
-
-
Serialized Fields
-
helper
SelectiveReceiveHelper<java.lang.Object> helper
-
state
SuspendableCallable<SuspendableCallable> state
-
-
-
Class co.paralleluniverse.actors.behaviors.ProxyServerActor extends ServerActor<ProxyServerActor.Invocation,java.lang.Object,ProxyServerActor.Invocation> implements Serializable
-
Serialized Fields
-
callOnVoidMethods
boolean callOnVoidMethods
-
interfaces
java.lang.Class<?>[] interfaces
-
target
java.lang.Object target
-
-
-
Class co.paralleluniverse.actors.behaviors.ProxyServerActor.Invocation extends java.lang.Object implements Serializable
-
Serialized Fields
-
method
java.lang.reflect.Method method
-
params
java.lang.Object[] params
-
-
-
Class co.paralleluniverse.actors.behaviors.RequestMessage extends ActorMessage implements Serializable
-
Serialized Fields
-
from
ActorRef from
-
id
java.lang.Object id
-
-
-
Class co.paralleluniverse.actors.behaviors.ResponseMessage extends ActorMessage implements Serializable
-
Serialized Fields
-
id
java.lang.Object id
-
-
-
Class co.paralleluniverse.actors.behaviors.Server extends Behavior implements Serializable
-
Serialized Fields
-
defaultTimeoutNanos
long defaultTimeoutNanos
-
-
-
Class co.paralleluniverse.actors.behaviors.ServerActor extends BehaviorActor implements Serializable
-
Serialized Fields
-
timeout
long timeout
-
timeoutUnit
java.util.concurrent.TimeUnit timeoutUnit
-
-
-
Class co.paralleluniverse.actors.behaviors.Supervisor extends Behavior implements Serializable
-
Class co.paralleluniverse.actors.behaviors.SupervisorActor extends BehaviorActor implements Serializable
-
Serialized Fields
-
children
java.util.List<co.paralleluniverse.actors.behaviors.SupervisorActor.ChildEntry> children
-
childrenById
java.util.concurrent.ConcurrentMap<java.lang.Object,co.paralleluniverse.actors.behaviors.SupervisorActor.ChildEntry> childrenById
-
childSpec
java.util.List<Supervisor.ChildSpec> childSpec
-
restartStrategy
SupervisorActor.RestartStrategy restartStrategy
-
-
-
Class co.paralleluniverse.actors.behaviors.SupervisorException extends java.lang.RuntimeException implements Serializable
-
Class co.paralleluniverse.actors.behaviors.ValueResponseMessage extends ResponseMessage implements Serializable
-
Serialized Fields
-
value
V value
-
-
-
-
Package co.paralleluniverse.fibers
-
Class co.paralleluniverse.fibers.Fiber extends Strand implements Serializable
- serialVersionUID:
- 2783452871536981L
-
Serialized Fields
-
fiberLocals
java.lang.Object fiberLocals
-
inheritableFiberLocals
java.lang.Object inheritableFiberLocals
-
initialStackSize
int initialStackSize
-
interrupted
boolean interrupted
-
interruptStack
java.lang.InterruptedException interruptStack
-
name
java.lang.String name
-
noLocals
boolean noLocals
-
priority
byte priority
-
run
long run
-
sleepStart
long sleepStart
-
stack
Stack stack
-
state
Strand.State state
-
target
SuspendableCallable<V> target
-
uncaughtExceptionHandler
Strand.UncaughtExceptionHandler uncaughtExceptionHandler
-
-
Class co.paralleluniverse.fibers.FiberAsync extends java.lang.Object implements Serializable
-
Class co.paralleluniverse.fibers.RuntimeExecutionException extends java.lang.RuntimeException implements Serializable
-
Class co.paralleluniverse.fibers.RuntimeSuspendExecution extends java.lang.RuntimeException implements Serializable
-
Class co.paralleluniverse.fibers.Stack extends java.lang.Object implements Serializable
- serialVersionUID:
- 12786283751253L
-
Serialized Fields
-
dataLong
long[] dataLong
-
dataObject
java.lang.Object[] dataObject
-
fiber
Fiber fiber
-
sp
int sp
-
-
Class co.paralleluniverse.fibers.SuspendExecution extends java.lang.Exception implements Serializable
-
Class co.paralleluniverse.fibers.VerifyInstrumentationException extends java.lang.RuntimeException implements Serializable
-
-
Package co.paralleluniverse.fibers.futures
-
Class co.paralleluniverse.fibers.futures.AsyncCompletionStage extends FiberAsync<V,java.util.concurrent.ExecutionException> implements Serializable
-
Serialized Fields
-
fut
java.util.concurrent.CompletionStage<V> fut
-
-
-
Class co.paralleluniverse.fibers.futures.AsyncListenableFuture extends FiberAsync<V,java.util.concurrent.ExecutionException> implements Serializable
-
Serialized Fields
-
fut
com.google.common.util.concurrent.ListenableFuture<V> fut
-
-
-
-
Package co.paralleluniverse.strands
-
Class co.paralleluniverse.strands.StrandLocalRandom extends java.util.Random implements Serializable
- serialVersionUID:
- -5851777807851030925L
-
Serialized Fields
-
initialized
boolean initialized
Initialization flag to permit calls to setSeed to succeed only while executing the Random constructor. We can't allow others since it would cause setting seed in one part of a program to unintentionally impact other usages by the thread. -
pad0
long pad0
-
pad1
long pad1
-
pad2
long pad2
-
pad3
long pad3
-
pad4
long pad4
-
pad5
long pad5
-
pad6
long pad6
-
pad7
long pad7
-
rnd
long rnd
The random seed. We can't use super.seed.
-
-
Class co.paralleluniverse.strands.SuspendableUtils.VoidSuspendableCallable extends java.lang.Object implements Serializable
-
Serialized Fields
-
runnable
SuspendableRunnable runnable
-
-
-
-
Package co.paralleluniverse.strands.channels
-
Class co.paralleluniverse.strands.channels.ChannelClosedException extends java.lang.RuntimeException implements Serializable
-
Class co.paralleluniverse.strands.channels.ProducerException extends java.lang.RuntimeException implements Serializable
-
Class co.paralleluniverse.strands.channels.QueueChannel extends java.lang.Object implements Serializable
-
Serialization Methods
-
writeReplace
protected java.lang.Object writeReplace() throws java.io.ObjectStreamException
- Throws:
java.io.ObjectStreamException
-
-
Serialized Fields
-
closeException
java.lang.Throwable closeException
-
overflowPolicy
Channels.OverflowPolicy overflowPolicy
-
queue
co.paralleluniverse.strands.queues.BasicQueue<Message> queue
-
receiveClosed
boolean receiveClosed
-
sendClosed
boolean sendClosed
-
sendersSync
Condition sendersSync
-
singleConsumer
boolean singleConsumer
-
singleProducer
boolean singleProducer
-
sync
Condition sync
-
-
-
Class co.paralleluniverse.strands.channels.QueueDoubleChannel extends QueuePrimitiveChannel<java.lang.Double> implements Serializable
-
Class co.paralleluniverse.strands.channels.QueueFloatChannel extends QueuePrimitiveChannel<java.lang.Float> implements Serializable
-
Class co.paralleluniverse.strands.channels.QueueIntChannel extends QueuePrimitiveChannel<java.lang.Integer> implements Serializable
-
Class co.paralleluniverse.strands.channels.QueueLongChannel extends QueuePrimitiveChannel<java.lang.Long> implements Serializable
-
Class co.paralleluniverse.strands.channels.QueueObjectChannel extends QueueChannel<Message> implements Serializable
-
Class co.paralleluniverse.strands.channels.QueuePrimitiveChannel extends QueueChannel<Message> implements Serializable
-
Serialized Fields
-
owner
Strand owner
-
-
-
Class co.paralleluniverse.strands.channels.ReceivePort.EOFException extends java.lang.Exception implements Serializable
-
Class co.paralleluniverse.strands.channels.SingleConsumerQueueChannel extends QueueChannel<Message> implements Serializable
-
Serialized Fields
-
owner
Strand owner
-
-
-
-
Package co.paralleluniverse.strands.channels.transfer
-
Class co.paralleluniverse.strands.channels.transfer.Pipeline extends java.lang.Object implements Serializable
-
Serialized Fields
-
closeTo
boolean closeTo
-
from
ReceivePort<? extends S> from
-
jobs
Channel<co.paralleluniverse.common.util.Pair<S,Channel<Channel<T>>>> jobs
-
parallelism
int parallelism
-
resultChannelBuilder
SuspendableCallable<Channel<T>> resultChannelBuilder
-
resultChannelBuilderDefault
SuspendableCallable<Channel<T>> resultChannelBuilderDefault
-
results
Channel<Channel<Channel<T>>> results
-
strandFactory
StrandFactory strandFactory
-
to
SendPort<? super T> to
-
transferred
java.util.concurrent.atomic.AtomicLong transferred
-
transformer
SuspendableAction2<S,Channel<T>> transformer
-
-
-
-
Package co.paralleluniverse.strands.concurrent
-
Class co.paralleluniverse.strands.concurrent.AbstractOwnableSynchronizer extends java.lang.Object implements Serializable
- serialVersionUID:
- 3737899427754241961L
-
Class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer extends AbstractOwnableSynchronizer implements Serializable
- serialVersionUID:
- 7373984972572414692L
-
Serialized Fields
-
state
long state
The synchronization state.
-
-
Class co.paralleluniverse.strands.concurrent.AbstractQueuedLongSynchronizer.ConditionObject extends java.lang.Object implements Serializable
- serialVersionUID:
- 1173984872572414699L
-
Class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer extends AbstractOwnableSynchronizer implements Serializable
- serialVersionUID:
- 7373984972572414691L
-
Serialized Fields
-
state
int state
The synchronization state.
-
-
Class co.paralleluniverse.strands.concurrent.AbstractQueuedSynchronizer.ConditionObject extends java.lang.Object implements Serializable
- serialVersionUID:
- 1173984872572414699L
-
Class co.paralleluniverse.strands.concurrent.ReentrantLock extends java.lang.Object implements Serializable
- serialVersionUID:
- 7373984872572414699L
-
Serialized Fields
-
sync
co.paralleluniverse.strands.concurrent.ReentrantLock.Sync sync
Synchronizer providing all implementation mechanics
-
-
Class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock extends java.lang.Object implements Serializable
- serialVersionUID:
- -6992448646407690164L
-
Serialized Fields
-
readerLock
ReentrantReadWriteLock.ReadLock readerLock
Inner class providing readlock -
sync
co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock.Sync sync
Performs all synchronization mechanics -
writerLock
ReentrantReadWriteLock.WriteLock writerLock
Inner class providing writelock
-
-
Class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock.ReadLock extends java.lang.Object implements Serializable
- serialVersionUID:
- -5992448646407690164L
-
Serialized Fields
-
sync
co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock.Sync sync
-
-
Class co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock.WriteLock extends java.lang.Object implements Serializable
- serialVersionUID:
- -4992448646407690164L
-
Serialized Fields
-
sync
co.paralleluniverse.strands.concurrent.ReentrantReadWriteLock.Sync sync
-
-
Class co.paralleluniverse.strands.concurrent.Semaphore extends java.lang.Object implements Serializable
- serialVersionUID:
- -3222578661600680210L
-
Serialized Fields
-
sync
co.paralleluniverse.strands.concurrent.Semaphore.Sync sync
All mechanics via AbstractQueuedSynchronizer subclass
-
-
Class co.paralleluniverse.strands.concurrent.StampedLock extends java.lang.Object implements Serializable
- serialVersionUID:
- -6001602636862214147L
-
Serialization Methods
-
readObject
private void readObject(java.io.ObjectInputStream s) throws java.io.IOException, java.lang.ClassNotFoundException
- Throws:
java.io.IOException
java.lang.ClassNotFoundException
-
-