In Files
- lib/concurrent/actor.rb
- lib/concurrent/edge/atomic_markable_reference.rb
- lib/concurrent/edge/lock_free_linked_set.rb
- lib/concurrent/edge/future.rb
- lib/concurrent/edge/lock_free_linked_set/node.rb
- lib/concurrent/edge/lock_free_linked_set/window.rb
- lib/concurrent/edge/lock_free_stack.rb
- lib/concurrent/actor/behaviour/buffer.rb
- lib/concurrent/actor/behaviour/linking.rb
- lib/concurrent/actor/behaviour/termination.rb
- lib/concurrent/actor/behaviour/supervising.rb
- lib/concurrent/actor/behaviour/removes_child.rb
- lib/concurrent/actor/behaviour/awaits.rb
- lib/concurrent/actor/behaviour/executes_context.rb
- lib/concurrent/actor/behaviour/errors_on_unknown_message.rb
- lib/concurrent/actor/behaviour/abstract.rb
- lib/concurrent/actor/behaviour/sets_results.rb
- lib/concurrent/actor/behaviour/pausing.rb
- lib/concurrent/actor/type_check.rb
- lib/concurrent/actor/public_delegations.rb
- lib/concurrent/actor/utils.rb
- lib/concurrent/actor/default_dead_letter_handler.rb
- lib/concurrent/actor/behaviour.rb
- lib/concurrent/actor/internal_delegations.rb
- lib/concurrent/actor/root.rb
- lib/concurrent/actor/core.rb
- lib/concurrent/actor/context.rb
- lib/concurrent/actor/envelope.rb
- lib/concurrent/actor/reference.rb
- lib/concurrent/actor/utils/pool.rb
- lib/concurrent/actor/utils/ad_hoc.rb
- lib/concurrent/actor/utils/balancer.rb
- lib/concurrent/actor/utils/broadcast.rb
- lib/concurrent/actor/errors.rb
- lib/concurrent/channel/selector/take_clause.rb
- lib/concurrent/channel/selector/after_clause.rb
- lib/concurrent/channel/selector/default_clause.rb
- lib/concurrent/channel/selector/error_clause.rb
- lib/concurrent/channel/selector/put_clause.rb
- lib/concurrent/channel/tick.rb
- lib/concurrent/channel/buffer/unbuffered.rb
- lib/concurrent/channel/buffer/buffered.rb
- lib/concurrent/channel/buffer/timer.rb
- lib/concurrent/channel/buffer/sliding.rb
- lib/concurrent/channel/buffer/base.rb
- lib/concurrent/channel/buffer/dropping.rb
- lib/concurrent/channel/buffer/ticker.rb
- lib/concurrent/channel/selector.rb
- lib/concurrent/channel.rb
Namespace
- MODULE Concurrent::Actor
- MODULE Concurrent::Edge
- CLASS Concurrent::Channel
Included Modules
Files
Class/Module Index
![[+]](./images/find.png "show/hide quicksearch")
- Concurrent
- Concurrent::Actor
- Concurrent::Actor::AbstractContext
- Concurrent::Actor::ActorTerminated
- Concurrent::Actor::Behaviour
- Concurrent::Actor::Behaviour::Abstract
- Concurrent::Actor::Behaviour::Awaits
- Concurrent::Actor::Behaviour::Buffer
- Concurrent::Actor::Behaviour::ErrorsOnUnknownMessage
- Concurrent::Actor::Behaviour::ExecutesContext
- Concurrent::Actor::Behaviour::Linking
- Concurrent::Actor::Behaviour::Pausing
- Concurrent::Actor::Behaviour::RemovesChild
- Concurrent::Actor::Behaviour::SetResults
- Concurrent::Actor::Behaviour::Supervising
- Concurrent::Actor::Behaviour::Termination
- Concurrent::Actor::Context
- Concurrent::Actor::Core
- Concurrent::Actor::DefaultDeadLetterHandler
- Concurrent::Actor::Envelope
- Concurrent::Actor::InternalDelegations
- Concurrent::Actor::PublicDelegations
- Concurrent::Actor::Reference
- Concurrent::Actor::RestartingContext
- Concurrent::Actor::Root
- Concurrent::Actor::TypeCheck
- Concurrent::Actor::UnknownMessage
- Concurrent::Actor::Utils
- Concurrent::Actor::Utils::AdHoc
- Concurrent::Actor::Utils::AsAdHoc
- Concurrent::Actor::Utils::Balancer
- Concurrent::Actor::Utils::Broadcast
- Concurrent::Actor::Utils::Pool
- Concurrent::Channel
- Concurrent::Channel::Buffer
- Concurrent::Channel::Buffer::Base
- Concurrent::Channel::Buffer::Buffered
- Concurrent::Channel::Buffer::Dropping
- Concurrent::Channel::Buffer::Sliding
- Concurrent::Channel::Buffer::Ticker
- Concurrent::Channel::Buffer::Timer
- Concurrent::Channel::Buffer::Unbuffered
- Concurrent::Channel::Selector
- Concurrent::Channel::Selector::AfterClause
- Concurrent::Channel::Selector::DefaultClause
- Concurrent::Channel::Selector::ErrorClause
- Concurrent::Channel::Selector::PutClause
- Concurrent::Channel::Selector::TakeClause
- Concurrent::Channel::Tick
- Concurrent::Channel::ValidationError
- Concurrent::Edge
- Concurrent::Edge::AbstractPromise
- Concurrent::Edge::AnyPromise
- Concurrent::Edge::AtomicMarkableReference
- Concurrent::Edge::AtomicMarkableReference::ImmutableArray
- Concurrent::Edge::BlockedPromise
- Concurrent::Edge::BlockedTaskPromise
- Concurrent::Edge::ChainPromise
- Concurrent::Edge::CompletableEvent
- Concurrent::Edge::CompletableEventPromise
- Concurrent::Edge::CompletableFuture
- Concurrent::Edge::CompletableFuturePromise
- Concurrent::Edge::Delay
- Concurrent::Edge::DelayValue
- Concurrent::Edge::Event
- Concurrent::Edge::Event::Completed
- Concurrent::Edge::Event::Pending
- Concurrent::Edge::Event::State
- Concurrent::Edge::EventWrapperPromise
- Concurrent::Edge::FlatPromise
- Concurrent::Edge::Future
- Concurrent::Edge::Future::CompletedWithResult
- Concurrent::Edge::Future::Failed
- Concurrent::Edge::Future::PartiallyFailed
- Concurrent::Edge::Future::Success
- Concurrent::Edge::Future::SuccessArray
- Concurrent::Edge::FutureShortcuts
- Concurrent::Edge::FutureWrapperPromise
- Concurrent::Edge::ImmediateEventPromise
- Concurrent::Edge::ImmediateFuturePromise
- Concurrent::Edge::InnerPromise
- Concurrent::Edge::LockFreeLinkedSet
- Concurrent::Edge::LockFreeLinkedSet::Head
- Concurrent::Edge::LockFreeLinkedSet::Node
- Concurrent::Edge::LockFreeLinkedSet::Tail
- Concurrent::Edge::LockFreeLinkedSet::Window
- Concurrent::Edge::LockFreeStack
- Concurrent::Edge::LockFreeStack::Empty
- Concurrent::Edge::LockFreeStack::Node
- Concurrent::Edge::RescuePromise
- Concurrent::Edge::ScheduledPromise
- Concurrent::Edge::ThenPromise
- Concurrent::Edge::ZipEventEventPromise
- Concurrent::Edge::ZipFutureEventPromise
- Concurrent::Edge::ZipFutureFuturePromise
- Concurrent::Edge::ZipPromise