Concurrent Ruby
Alphabetic Index
File Listing
README
thread_pools
promises.out
medium-example.out
LICENSE
CHANGELOG
Namespace Listing A-Z
A
Abstract
(Concurrent::Actor::Behaviour)
AbstractContext
(Concurrent::Actor)
AbstractEventFuture
(Concurrent::Promises)
AbstractLogicOperationMatcher
(Concurrent::ErlangActor::EnvironmentConstants)
Actor
(Concurrent)
ActorIntegration
(Concurrent::Promises::Future)
ActorTerminated
(Concurrent::Actor)
AdHoc
(Concurrent::Actor::Utils)
AfterClause
(Concurrent::Channel::Selector)
Agent
(Concurrent)
And
(Concurrent::ErlangActor::EnvironmentConstants)
Array
(Concurrent)
AsAdHoc
(Concurrent::Actor::Utils)
Async
(Concurrent)
Atom
(Concurrent)
AtomicBoolean
(Concurrent)
AtomicFixnum
(Concurrent)
AtomicMarkableReference
(Concurrent)
AtomicReference
(Concurrent)
Awaits
(Concurrent::Actor::Behaviour)
B
Balancer
(Concurrent::Actor::Utils)
Base
(Concurrent::Channel::Buffer)
Behaviour
(Concurrent::Actor)
Broadcast
(Concurrent::Actor::Utils)
Buffer
(Concurrent::Actor::Behaviour)
Buffer
(Concurrent::Channel)
Buffered
(Concurrent::Channel::Buffer)
C
CachedThreadPool
(Concurrent)
Cancellation
(Concurrent)
Channel
(Concurrent)
Channel
(Concurrent::Promises)
ClassMethods
(Concurrent::Synchronization::Volatile)
Concern
(Concurrent)
Concurrent
ConcurrentUpdateError
(Concurrent)
Configuration
(Concurrent::Promises::FactoryMethods)
Context
(Concurrent::Actor)
CopyOnNotifyObserverSet
(Concurrent::Collection)
CopyOnWriteObserverSet
(Concurrent::Collection)
Core
(Concurrent::Actor)
CountDownLatch
(Concurrent)
CyclicBarrier
(Concurrent)
D
DefaultClause
(Concurrent::Channel::Selector)
DefaultDeadLetterHandler
(Concurrent::Actor)
Delay
(Concurrent)
Dereferenceable
(Concurrent::Concern)
Down
(Concurrent::ErlangActor)
Dropping
(Concurrent::Channel::Buffer)
E
Edge
(Concurrent)
Envelope
(Concurrent::Actor)
Environment
(Concurrent::ErlangActor)
EnvironmentConstants
(Concurrent::ErlangActor)
ErlangActor
(Concurrent)
Error
(Concurrent::Agent)
Error
(Concurrent::ErlangActor)
ErrorClause
(Concurrent::Channel::Selector)
ErrorsOnUnknownMessage
(Concurrent::Actor::Behaviour)
Event
(Concurrent)
Event
(Concurrent::Promises)
Exchanger
(Concurrent)
ExecutesContext
(Concurrent::Actor::Behaviour)
F
FactoryMethods
(Concurrent::Promises)
FiberLocalVar
(Concurrent)
FixedThreadPool
(Concurrent)
FlatShortcuts
(Concurrent::Promises::Future)
FunctionShortcuts
(Concurrent::ErlangActor)
Functions
(Concurrent::ErlangActor)
Future
(Concurrent)
Future
(Concurrent::Promises)
H
Hash
(Concurrent)
Head
(Concurrent::Edge::LockFreeLinkedSet)
I
IVar
(Concurrent)
ImmediateExecutor
(Concurrent)
ImmutableStruct
(Concurrent)
IndirectImmediateExecutor
(Concurrent)
InternalDelegations
(Concurrent::Actor)
J
Job
(Concurrent::SerializedExecution)
L
LazyRegister
(Concurrent)
Linking
(Concurrent::Actor::Behaviour)
LockFreeLinkedSet
(Concurrent::Edge)
LockFreeStack
(Concurrent)
LockLocalVar
(Concurrent)
M
MVar
(Concurrent)
Map
(Concurrent)
Maybe
(Concurrent)
MultipleAssignmentError
(Concurrent)
MultipleErrors
(Concurrent)
MutableStruct
(Concurrent)
N
NewChannelIntegration
(Concurrent::Promises::Future)
NoActor
(Concurrent::ErlangActor)
NoReply
(Concurrent::ErlangActor)
Node
(Concurrent::Edge::LockFreeLinkedSet)
Node
(Concurrent::LockFreeQueue)
Node
(Concurrent::LockFreeStack)
O
Obligation
(Concurrent::Concern)
Observable
(Concurrent::Concern)
OpenEntry
(Concurrent::Transaction)
Or
(Concurrent::ErlangActor::EnvironmentConstants)
P
Pausing
(Concurrent::Actor::Behaviour)
Pid
(Concurrent::ErlangActor)
Pool
(Concurrent::Actor::Utils)
ProcessingActor
(Concurrent)
Promise
(Concurrent)
Promises
(Concurrent)
PublicDelegations
(Concurrent::Actor)
PutClause
(Concurrent::Channel::Selector)
R
ReadWriteLock
(Concurrent)
ReentrantReadWriteLock
(Concurrent)
Reference
(Concurrent::Actor)
Reference
(Concurrent::ErlangActor)
RemovesChild
(Concurrent::Actor::Behaviour)
Resolvable
(Concurrent::Promises)
ResolvableEvent
(Concurrent::Promises)
ResolvableFuture
(Concurrent::Promises)
RestartingContext
(Concurrent::Actor)
Root
(Concurrent::Actor)
S
SafeTaskExecutor
(Concurrent)
ScheduledTask
(Concurrent)
Semaphore
(Concurrent)
SerializedExecution
(Concurrent)
SerializedExecutionDelegator
(Concurrent)
Set
(Concurrent)
SetResults
(Concurrent::Actor::Behaviour)
SettableStruct
(Concurrent)
SimpleExecutorService
(Concurrent)
SingleThreadExecutor
(Concurrent)
Sliding
(Concurrent::Channel::Buffer)
Supervising
(Concurrent::Actor::Behaviour)
T
TVar
(Concurrent)
Tail
(Concurrent::Edge::LockFreeLinkedSet)
TakeClause
(Concurrent::Channel::Selector)
Terminated
(Concurrent::ErlangActor)
Termination
(Concurrent::Actor::Behaviour)
ThreadLocalVar
(Concurrent)
ThreadPoolExecutor
(Concurrent)
Throttle
(Concurrent)
Tick
(Concurrent::Channel)
Ticker
(Concurrent::Channel::Buffer)
Timer
(Concurrent::Channel::Buffer)
TimerSet
(Concurrent)
TimerTask
(Concurrent)
Tuple
(Concurrent)
TypeCheck
(Concurrent::Actor)
U
Unbuffered
(Concurrent::Channel::Buffer)
UnknownMessage
(Concurrent::Actor)
Utils
(Concurrent::Actor)
V
ValidationError
(Concurrent::Agent)
ValidationError
(Concurrent::Channel)
W
Window
(Concurrent::Edge::LockFreeLinkedSet)
WrappingExecutor
(Concurrent)
X
XorShiftRandom
(Concurrent::ThreadSafe::Util)