In Files
- lib/concurrent/agent.rb
- lib/concurrent/actor.rb
- lib/concurrent/edge/future.rb
- lib/concurrent/edge/lock_free_stack.rb
- lib/concurrent/edge/atomic_markable_reference.rb
- lib/concurrent/actor/behaviour/buffer.rb
- lib/concurrent/actor/behaviour/awaits.rb
- lib/concurrent/actor/behaviour/abstract.rb
- lib/concurrent/actor/behaviour/linking.rb
- lib/concurrent/actor/behaviour/sets_results.rb
- lib/concurrent/actor/behaviour/terminates_children.rb
- lib/concurrent/actor/behaviour/removes_child.rb
- lib/concurrent/actor/behaviour/executes_context.rb
- lib/concurrent/actor/behaviour/errors_on_unknown_message.rb
- lib/concurrent/actor/behaviour/supervising.rb
- lib/concurrent/actor/behaviour/termination.rb
- lib/concurrent/actor/behaviour/pausing.rb
- lib/concurrent/actor/public_delegations.rb
- lib/concurrent/actor/root.rb
- lib/concurrent/actor/default_dead_letter_handler.rb
- lib/concurrent/actor/errors.rb
- lib/concurrent/actor/core.rb
- lib/concurrent/actor/utils/broadcast.rb
- lib/concurrent/actor/utils/pool.rb
- lib/concurrent/actor/utils/balancer.rb
- lib/concurrent/actor/utils/ad_hoc.rb
- lib/concurrent/actor/type_check.rb
- lib/concurrent/actor/internal_delegations.rb
- lib/concurrent/actor/behaviour.rb
- lib/concurrent/actor/context.rb
- lib/concurrent/actor/utils.rb
- lib/concurrent/actor/reference.rb
- lib/concurrent/actor/envelope.rb
- lib/concurrent/channel/buffered_channel.rb
- lib/concurrent/channel/blocking_ring_buffer.rb
- lib/concurrent/channel/channel.rb
- lib/concurrent/channel/ring_buffer.rb
- lib/concurrent/channel/unbuffered_channel.rb
- lib/concurrent/channel/waitable_list.rb
Namespace
- MODULE Concurrent::Actor
- MODULE Concurrent::Channel
- MODULE Concurrent::Edge
- CLASS Concurrent::Agent
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::TerminatesChildren
- 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::Agent
- Concurrent::Channel
- Concurrent::Channel::BlockingRingBuffer
- Concurrent::Channel::BufferedChannel
- Concurrent::Channel::RingBuffer
- Concurrent::Channel::UnbufferedChannel
- Concurrent::Channel::WaitableList
- 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::Channel
- 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::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