Method List

Classes Methods Files

Search:

<< Concurrent::PerThreadExecutor
#<< Concurrent::Agent
#<< Concurrent::ImmediateExecutor
#<< Concurrent::RubyExecutor
#<< Concurrent::JavaExecutor
#<< Concurrent::PerThreadExecutor
#== Concurrent::Actor::Reference
#Child! Concurrent::Actor::TypeCheck
#Child? Concurrent::Actor::TypeCheck
#Match! Concurrent::Actor::TypeCheck
#Match? Concurrent::Actor::TypeCheck
#Type! Concurrent::Actor::TypeCheck
#Type? Concurrent::Actor::TypeCheck
#[] Concurrent::LazyRegister
#_compare_and_set Concurrent::CAtomic
#_compare_and_set Concurrent::MutexAtomic
#abort Concurrent::Transaction
abort_transaction Concurrent
#actor_class Concurrent::Actor::Core
#add_child Concurrent::Actor::Core
#add_observer Concurrent::ScheduledTask
#add_observer Concurrent::CopyOnNotifyObserverSet
#add_observer Concurrent::CopyOnWriteObserverSet
#add_observer Concurrent::Observable
#add_observer Concurrent::IVar
#address Concurrent::Actor::Envelope
#address_path Concurrent::Actor::Envelope
#allocate_context Concurrent::Actor::Core
#args Concurrent::SerializedExecution::Job
#ask Concurrent::Actor::AbstractContext
#ask Concurrent::Actor::Reference
#ask! Concurrent::Actor::Reference
#async Concurrent::Async
atomically Concurrent
#auto_terminate Concurrent::Configuration
#await Concurrent::Agent
#await Concurrent::Async
base Concurrent::Actor::Behaviour
basic_behaviour_definition Concurrent::Actor::Behaviour
#behaviour Concurrent::Actor::Core
#behaviour Concurrent::Actor::InternalDelegations
#behaviour! Concurrent::Actor::Core
#behaviour! Concurrent::Actor::InternalDelegations
#behaviour_definition Concurrent::Actor::RestartingContext
#behaviour_definition Concurrent::Actor::Root
#behaviour_definition Concurrent::Actor::Context
#behaviour_definition Concurrent::Actor::AbstractContext
#behaviour_definition Concurrent::Actor::Core
#bind Concurrent::AbstractThreadLocalVar
#block Concurrent::SerializedExecution::Job
#broadcast Concurrent::Condition
#broadcast Concurrent::Actor::Core
#broadcast Concurrent::Actor::Behaviour::Abstract
#broken? Concurrent::CyclicBarrier
#buffer_queue_size Concurrent::BufferedChannel
#build_context Concurrent::Actor::Core
calculate_schedule_time Concurrent::TimerSet
#call Concurrent::SerializedExecution::Job
call_dataflow Concurrent
#can_overflow? Concurrent::RubyThreadPoolExecutor
#can_overflow? Concurrent::JavaThreadPoolExecutor
#can_overflow? Concurrent::Executor
#cancel Concurrent::ScheduledTask
#cancelled? Concurrent::ScheduledTask
#capacity Concurrent::BlockingRingBuffer
#capacity Concurrent::RingBuffer
#channel Concurrent::Channel::Probe
#children Concurrent::Actor::Core
#children Concurrent::Actor::InternalDelegations
#clear Concurrent::MutexPriorityQueue
#clear Concurrent::JavaPriorityQueue
#commit Concurrent::Transaction
#compare_and_set Concurrent
#compare_and_set Concurrent::MutexAtomicFixnum
#compare_and_set Concurrent::AtomicNumericCompareAndSetWrapper
#compare_and_set Concurrent::JavaAtomicFixnum
#completed? Concurrent::Obligation
#completed_task_count Concurrent::RubyThreadPoolExecutor
#completed_task_count Concurrent::JavaThreadPoolExecutor
#composite_value Concurrent::Channel::Probe
configuration Concurrent
configure Concurrent
#context Concurrent::Actor::Core
#context Concurrent::Actor::InternalDelegations
#context_class Concurrent::Actor::Core
#context_class Concurrent::Actor::PublicDelegations
#core Concurrent::Actor::AbstractContext
#core Concurrent::Actor::Behaviour::Abstract
#count Concurrent::JavaCountDownLatch
#count Concurrent::MutexCountDownLatch
#count Concurrent::BlockingRingBuffer
#count Concurrent::RingBuffer
#count_down Concurrent::JavaCountDownLatch
#count_down Concurrent::MutexCountDownLatch
#count_observers Concurrent::Observable
#count_observers Concurrent::CopyOnWriteObserverSet
#count_observers Concurrent::CopyOnNotifyObserverSet
current Concurrent::Actor
current Concurrent::Transaction
current= Concurrent::Transaction
dataflow Concurrent
dataflow! Concurrent
dataflow_with Concurrent
dataflow_with! Concurrent
#dead_letter_routing Concurrent::Actor::Reference
#dead_letter_routing Concurrent::Actor::AbstractContext
#dead_letter_routing Concurrent::Actor::Root
#dead_letter_routing Concurrent::Actor::Core
#dead_letter_routing Concurrent::Actor::InternalDelegations
#decrement Concurrent
#decrement Concurrent::JavaAtomicFixnum
#decrement Concurrent::MutexAtomicFixnum
#default_reference_class Concurrent::Actor::AbstractContext
#delete Concurrent::MutexPriorityQueue
#delete Concurrent::JavaPriorityQueue
#delete Concurrent::WaitableList
#delete_observer Concurrent::CopyOnWriteObserverSet
#delete_observer Concurrent::Observable
#delete_observer Concurrent::CopyOnNotifyObserverSet
#delete_observers Concurrent::CopyOnNotifyObserverSet
#delete_observers Concurrent::CopyOnWriteObserverSet
#delete_observers Concurrent::Observable
#distribute Concurrent::Actor::Utils::Balancer
#empty? Concurrent::RingBuffer
#empty? Concurrent::MutexPriorityQueue
#empty? Concurrent::JavaPriorityQueue
#empty? Concurrent::BlockingRingBuffer
#empty? Concurrent::MVar
#empty? Concurrent::WaitableList
#envelope Concurrent::Actor::AbstractContext
#envelope Concurrent::Actor::UnknownMessage
#error_strategy Concurrent::Actor::Behaviour::SetResults
#exception Concurrent::Obligation
#exchange Concurrent::Exchanger
#execute Concurrent::Promise
execute Concurrent::Promise
#execute Concurrent::Future
execute Concurrent::Future
execute Concurrent::ScheduledTask
#execute Concurrent::SafeTaskExecutor
#execute Concurrent::ScheduledTask
#execute Concurrent::TimerTask
execute Concurrent::TimerTask
#execution_interval Concurrent::TimerTask
#executor Concurrent::Actor::Core
#executor Concurrent::Actor::PublicDelegations
#executor Concurrent::SerializedExecution::Job
#executor= Concurrent::Async
#fail Concurrent::IVar
#false? Concurrent::JavaAtomicBoolean
#false? Concurrent::MutexAtomicBoolean
#false? Concurrent
#filtered_receivers Concurrent::Actor::Utils::Broadcast
finalize_global_executors Concurrent
#flat_map Concurrent::Promise
from_list Concurrent::JavaPriorityQueue
from_list Concurrent::MutexPriorityQueue
fulfill Concurrent::Promise
#fulfilled? Concurrent::Obligation
#full? Concurrent::MVar
#full? Concurrent::BlockingRingBuffer
#full? Concurrent::RingBuffer
#get Concurrent::MutexAtomic
#get Concurrent::CAtomic
#get_and_set Concurrent::MutexAtomic
#get_and_set Concurrent::CAtomic
#get_executor_from Concurrent::OptionsParser
#get_operation_executor_from Concurrent::OptionsParser
#get_task_executor_from Concurrent::OptionsParser
#global_operation_pool Concurrent::Configuration
#global_operation_pool= Concurrent::Configuration
#global_task_pool Concurrent::Configuration
#global_task_pool= Concurrent::Configuration
#global_timer_set Concurrent::Configuration
#guard! Concurrent::Actor::Core
i_know_it_is_experimental! Concurrent::Actor
#idletime Concurrent::JavaThreadPoolExecutor
#idletime Concurrent::RubyThreadPoolExecutor
#in_progress? Concurrent::ScheduledTask
#include? Concurrent::JavaPriorityQueue
#include? Concurrent::MutexPriorityQueue
#incomplete? Concurrent::Obligation
#increment Concurrent
#increment Concurrent::JavaAtomicFixnum
#increment Concurrent::MutexAtomicFixnum
#init_mutex Concurrent::Async
#initialize Concurrent::LazyRegister
#initialize Concurrent::MutexAtomic
#initialize Concurrent::Actor::Utils::Broadcast
#initialize Concurrent::JavaPriorityQueue
#initialize Concurrent::Configuration
#initialize Concurrent::CyclicBarrier
#initialize Concurrent::CAtomic
#initialize Concurrent::JavaAtomicFixnum
#initialize Concurrent::SafeTaskExecutor
#initialize Concurrent::MutexPriorityQueue
#initialize Concurrent::Actor::Behaviour::Linking
#initialize Concurrent::Actor::ActorTerminated
#initialize Concurrent::JavaCachedThreadPool
#initialize Concurrent::Actor::UnknownMessage
#initialize Concurrent::TimerTask
#initialize Concurrent::Event
#initialize Concurrent::IndirectImmediateExecutor
#initialize Concurrent::RubyThreadPoolExecutor
#initialize Concurrent::Actor::Root
#initialize Concurrent::JavaThreadPoolExecutor
#initialize Concurrent::ProcessorCounter
#initialize Concurrent::RingBuffer
#initialize Concurrent::Actor::Core
#initialize Concurrent::JavaSingleThreadExecutor
#initialize Concurrent::Exchanger
#initialize Concurrent::BlockingRingBuffer
#initialize Concurrent::AbstractThreadLocalVar
#initialize Concurrent::Actor::Envelope
#initialize Concurrent::Actor::Behaviour::Pausing
#initialize Concurrent::Actor::Behaviour::Buffer
#initialize Concurrent::Promise
#initialize Concurrent::Future
#initialize Concurrent::Delay
#initialize Concurrent::CopyOnWriteObserverSet
#initialize Concurrent::JavaAtomicBoolean
#initialize Concurrent::Agent
#initialize Concurrent::CopyOnNotifyObserverSet
#initialize Concurrent::SerializedExecutionDelegator
#initialize Concurrent::SerializedExecution
#initialize Concurrent::JavaCountDownLatch
#initialize Concurrent::MutexCountDownLatch
#initialize Concurrent::Transaction
#initialize Concurrent::RubySingleThreadExecutor
#initialize Concurrent::RubyFixedThreadPool
#initialize Concurrent::JavaFixedThreadPool
#initialize Concurrent::TVar
#initialize Concurrent::Actor::Behaviour::Termination
#initialize Concurrent::IVar
#initialize Concurrent::MVar
#initialize Concurrent
#initialize Concurrent::PerThreadExecutor
#initialize Concurrent::Actor::Behaviour::Supervising
#initialize Concurrent::Condition::Result
#initialize Concurrent::Actor::Utils::AbstractWorker
#initialize Concurrent::ImmediateExecutor
#initialize Concurrent::Actor::Behaviour::Abstract
#initialize Concurrent::Condition
#initialize Concurrent::Actor::Behaviour::Supervised
#initialize Concurrent::WaitableList
#initialize Concurrent::Channel::Probe
#initialize Concurrent::Actor::Utils::Pool
#initialize Concurrent::RubyCachedThreadPool
#initialize Concurrent::BufferedChannel
#initialize Concurrent::MutexAtomicBoolean
#initialize Concurrent::ScheduledTask
#initialize Concurrent::Actor::Behaviour::SetResults
#initialize Concurrent::UnbufferedChannel
#initialize Concurrent::MutexAtomicFixnum
#initialize Concurrent::TimerSet
#initialize Concurrent::Actor::Utils::AdHoc
#initialize Concurrent::Actor::Utils::Balancer
#ivar Concurrent::Actor::Envelope
#kill Concurrent::JavaExecutor
#kill Concurrent::RubyExecutor
#kill Concurrent::PerThreadExecutor
#kill Concurrent::TimerSet
#largest_length Concurrent::JavaThreadPoolExecutor
#largest_length Concurrent::RubyThreadPoolExecutor
#length Concurrent::JavaThreadPoolExecutor
#length Concurrent::MutexPriorityQueue
#length Concurrent::JavaPriorityQueue
#length Concurrent::RubyThreadPoolExecutor
#link Concurrent::Actor::Behaviour::Linking
#log Concurrent::Actor::Core
#log Concurrent::Actor::InternalDelegations
#log Concurrent::Logging
#logger Concurrent::Configuration
#make_false Concurrent::JavaAtomicBoolean
#make_false Concurrent::MutexAtomicBoolean
#make_false Concurrent
#make_true Concurrent
#make_true Concurrent::JavaAtomicBoolean
#make_true Concurrent::MutexAtomicBoolean
#max_length Concurrent::RubyThreadPoolExecutor
#max_length Concurrent::JavaThreadPoolExecutor
#max_queue Concurrent::JavaThreadPoolExecutor
#max_queue Concurrent::RubyThreadPoolExecutor
#message Concurrent::Actor::Envelope
#message Concurrent::Actor::Reference
#min_length Concurrent::JavaThreadPoolExecutor
#min_length Concurrent::RubyThreadPoolExecutor
#modify Concurrent::MVar
#modify! Concurrent::MVar
#name Concurrent::Actor::PublicDelegations
#name Concurrent::Actor::Core
#new_operation_pool Concurrent::Configuration
#new_task_pool Concurrent::Configuration
#no_error! Concurrent::Obligation
#no_logger Concurrent::Configuration
#notify_and_delete_observers Concurrent::CopyOnWriteObserverSet
#notify_and_delete_observers Concurrent::CopyOnNotifyObserverSet
#notify_observers Concurrent::CopyOnWriteObserverSet
#notify_observers Concurrent::CopyOnNotifyObserverSet
#number_waiting Concurrent::CyclicBarrier
#offer Concurrent::RingBuffer
#on_envelope Concurrent::Actor::Behaviour::Awaits
#on_envelope Concurrent::Actor::Behaviour::Supervised
#on_envelope Concurrent::Actor::Behaviour::Abstract
#on_envelope Concurrent::Actor::Behaviour::RemovesChild
#on_envelope Concurrent::Actor::Behaviour::ErrorsOnUnknownMessage
#on_envelope Concurrent::Actor::Behaviour::SetResults
#on_envelope Concurrent::Actor::Behaviour::Termination
#on_envelope Concurrent::Actor::Behaviour::Buffer
#on_envelope Concurrent::Actor::AbstractContext
#on_envelope Concurrent::Actor::Behaviour::ExecutesContext
#on_envelope Concurrent::Actor::Core
#on_envelope Concurrent::Actor::Behaviour::Linking
#on_envelope Concurrent::Actor::Behaviour::Supervising
#on_envelope Concurrent::Actor::Behaviour::Pausing
#on_event Concurrent::Actor::Behaviour::ExecutesContext
#on_event Concurrent::Actor::Behaviour::Pausing
#on_event Concurrent::Actor::Behaviour::Buffer
#on_event Concurrent::Actor::Behaviour::Abstract
#on_event Concurrent::Actor::AbstractContext
#on_event Concurrent::Actor::Behaviour::TerminatesChildren
#on_event Concurrent::Actor::Behaviour::Supervised
#on_event Concurrent::Actor::Behaviour::Linking
#on_message Concurrent::Actor::Utils::Broadcast
#on_message Concurrent::Actor::Utils::Balancer
#on_message Concurrent::Actor::Utils::AdHoc
#on_message Concurrent::Actor::Utils::Pool
#on_message Concurrent::Actor::Utils::AbstractWorker
#on_message Concurrent::Actor::AbstractContext
#on_message Concurrent::Actor::Root
#on_message Concurrent::Actor::DefaultDeadLetterHandler
#on_success Concurrent::Promise
#operation_executor Concurrent::Agent
#overflow_policy Concurrent::JavaThreadPoolExecutor
#overflow_policy Concurrent::RubyThreadPoolExecutor
#parent Concurrent::Actor::Core
#parent Concurrent::Actor::PublicDelegations
#parties Concurrent::CyclicBarrier
#pass Concurrent::Actor::Behaviour::Abstract
#pass Concurrent::Actor::AbstractContext
#path Concurrent::Actor::Core
#path Concurrent::Actor::PublicDelegations
#pause! Concurrent::Actor::Behaviour::Pausing
#peek Concurrent::BlockingRingBuffer
#peek Concurrent::MutexPriorityQueue
#peek Concurrent::JavaPriorityQueue
#peek Concurrent::RingBuffer
#pending? Concurrent::Obligation
physical_processor_count Concurrent
#physical_processor_count Concurrent::ProcessorCounter
#poll Concurrent::RingBuffer
#pop Concurrent::UnbufferedChannel
#pop Concurrent::MutexPriorityQueue
#pop Concurrent::BufferedChannel
#pop Concurrent::JavaPriorityQueue
post Concurrent::PerThreadExecutor
#post Concurrent::TimerSet
#post Concurrent::JavaExecutor
#post Concurrent::RubyExecutor
#post Concurrent::IndirectImmediateExecutor
#post Concurrent::SerializedExecutionDelegator
#post Concurrent::PerThreadExecutor
#post Concurrent::Agent
#post Concurrent::SerializedExecution
#post Concurrent::ImmediateExecutor
#post_off Concurrent::Agent
#posts Concurrent::SerializedExecution
#probe_set_size Concurrent::UnbufferedChannel
#probe_set_size Concurrent::BufferedChannel
#process_envelope Concurrent::Actor::Behaviour::Buffer
#process_envelopes? Concurrent::Actor::Behaviour::Buffer
processor_count Concurrent
#processor_count Concurrent::ProcessorCounter
#push Concurrent::UnbufferedChannel
#push Concurrent::MutexPriorityQueue
#push Concurrent::JavaPriorityQueue
#push Concurrent::BufferedChannel
#put Concurrent::BlockingRingBuffer
#put Concurrent::MVar
#put Concurrent::WaitableList
#queue_length Concurrent::RubyThreadPoolExecutor
#queue_length Concurrent::JavaThreadPoolExecutor
#read Concurrent::Transaction
#reason Concurrent::Obligation
#reconfigure Concurrent::Delay
#redirect Concurrent::Actor::InternalDelegations
#reference Concurrent::Actor::PublicDelegations
#reference Concurrent::Actor::ActorTerminated
#reference Concurrent::Actor::Core
#register Concurrent::LazyRegister
#registered? Concurrent::LazyRegister
reject Concurrent::Promise
#reject! Concurrent::Actor::Envelope
#reject_envelope Concurrent::Actor::Behaviour::Abstract
#rejected? Concurrent::Obligation
#remaining_capacity Concurrent::RubyThreadPoolExecutor
#remaining_capacity Concurrent::JavaThreadPoolExecutor
#remaining_time Concurrent::Condition::Result
#remove_child Concurrent::Actor::Core
#remove_probe Concurrent::UnbufferedChannel
#remove_probe Concurrent::BufferedChannel
#rescue Concurrent::Promise
#rescue Concurrent::Agent
#reset Concurrent::Event
#reset Concurrent::CyclicBarrier
#reset! Concurrent::Actor::Behaviour::Pausing
#restart! Concurrent::Actor::Behaviour::Pausing
restarting_behaviour_definition Concurrent::Actor::Behaviour
#resume! Concurrent::Actor::Behaviour::Pausing
root Concurrent::Actor
#running? Concurrent::JavaThreadPoolExecutor
#running? Concurrent::PerThreadExecutor
#running? Concurrent::RubyExecutor
#running? Concurrent::JavaExecutor
#running? Concurrent::TimerTask
#running? Concurrent::ImmediateExecutor
#schedule_execution Concurrent::Actor::Core
#schedule_time Concurrent::ScheduledTask
#scheduled_task_count Concurrent::JavaThreadPoolExecutor
#scheduled_task_count Concurrent::RubyThreadPoolExecutor
#select Concurrent::UnbufferedChannel
select Concurrent::Channel
#select Concurrent::BufferedChannel
#sender Concurrent::Actor::Envelope
#sender_path Concurrent::Actor::Envelope
#serialized? Concurrent::Executor
#serialized? Concurrent::SerialExecutor
#set Concurrent::MutexAtomic
#set Concurrent::Event
#set Concurrent::IVar
#set Concurrent::CAtomic
#set! Concurrent::MVar
#set? Concurrent::Event
#set_unless_assigned Concurrent::Channel::Probe
#shutdown Concurrent::JavaExecutor
#shutdown Concurrent::RubyExecutor
#shutdown Concurrent::PerThreadExecutor
#shutdown Concurrent::ImmediateExecutor
#shutdown? Concurrent::JavaExecutor
#shutdown? Concurrent::RubyExecutor
#shutdown? Concurrent::PerThreadExecutor
#shutdown? Concurrent::ImmediateExecutor
#shuttingdown? Concurrent::JavaExecutor
#shuttingdown? Concurrent::RubyExecutor
#shuttingdown? Concurrent::PerThreadExecutor
#shuttingdown? Concurrent::ImmediateExecutor
#signal Concurrent::Condition
#size Concurrent::WaitableList
spawn Concurrent::Actor
spawn! Concurrent::Actor
spawn_optionify Concurrent::Actor
#state Concurrent::Obligation
#status Concurrent::JavaThreadPoolExecutor
#status Concurrent::RubyThreadPoolExecutor
#subsequent Concurrent::Actor::Behaviour::Abstract
#supervise Concurrent::Actor::Behaviour::Supervised
supervised Concurrent::Actor::Behaviour
#supervisor Concurrent::Actor::Behaviour::Supervised
#take Concurrent::WaitableList
#take Concurrent::MVar
#take Concurrent::BlockingRingBuffer
#task_executor Concurrent::Agent
#tell Concurrent::Actor::Reference
#tell Concurrent::Actor::AbstractContext
#terminate! Concurrent::Actor::Behaviour::Termination
#terminate! Concurrent::Actor::InternalDelegations
#terminated Concurrent::Actor::Behaviour::Termination
#terminated? Concurrent::Actor::Behaviour::Termination
#then Concurrent::Promise
#timed_out? Concurrent::Condition::Result
timeout Concurrent
#timeout Concurrent::Agent
#timeout_interval Concurrent::TimerTask
timer Concurrent
#to_s Concurrent::Actor::Reference
#true? Concurrent
#true? Concurrent::JavaAtomicBoolean
#true? Concurrent::MutexAtomicBoolean
#try? Concurrent::Event
#try_put! Concurrent::MVar
#try_take! Concurrent::MVar
#try_update Concurrent::AtomicDirectUpdate
#tvar Concurrent::Transaction::UndoLogEntry
#tvar Concurrent::Transaction::ReadLogEntry
#un_supervise Concurrent::Actor::Behaviour::Supervised
#unlink Concurrent::Actor::Behaviour::Linking
#unlock Concurrent::Transaction
#unregister Concurrent::LazyRegister
#unscheduled? Concurrent::Obligation
#update Concurrent::AtomicDirectUpdate
user_messages Concurrent::Actor::Behaviour
#valid? Concurrent::Transaction
#validate Concurrent::Agent
validate_argc Concurrent::Async
#value Concurrent::AbstractThreadLocalVar
#value Concurrent::JavaAtomicBoolean
#value Concurrent::MutexAtomicBoolean
#value Concurrent
#value Concurrent::JavaAtomicFixnum
#value Concurrent::MutexAtomicFixnum
#value Concurrent::Dereferenceable
#value Concurrent::Channel::Probe
#value Concurrent::Obligation
#value Concurrent::Transaction::UndoLogEntry
#value Concurrent::TVar
#value! Concurrent::Obligation
#value= Concurrent::AbstractThreadLocalVar
#value= Concurrent::JavaAtomicBoolean
#value= Concurrent::MutexAtomicBoolean
#value= Concurrent
#value= Concurrent::JavaAtomicFixnum
#value= Concurrent::MutexAtomicFixnum
#value= Concurrent::TVar
#version Concurrent::Transaction::ReadLogEntry
#wait Concurrent::JavaCountDownLatch
#wait Concurrent::MutexCountDownLatch
#wait Concurrent::CyclicBarrier
#wait Concurrent::Condition
#wait Concurrent::Event
#wait Concurrent::Obligation
#wait Concurrent::Delay
#wait_for_termination Concurrent::PerThreadExecutor
#wait_for_termination Concurrent::ImmediateExecutor
#wait_for_termination Concurrent::JavaExecutor
#wait_for_termination Concurrent::RubyExecutor
#with_observer Concurrent::Observable
#woken_up? Concurrent::Condition::Result
#work Concurrent::Actor::Utils::AbstractWorker
#write Concurrent::Transaction
#zip Concurrent::Promise
zip Concurrent::Promise