@!macro thread_pool_executor @!macro thread_pool_options @!visibility private
@!macro thread_pool_executor_constant_default_max_pool_size
@!macro thread_pool_executor_constant_default_max_queue_size
@!macro thread_pool_executor_constant_default_min_pool_size
@!macro thread_pool_executor_constant_default_thread_timeout
@!macro executor_service_method_can_overflow_question
# File lib/concurrent/executor/ruby_thread_pool_executor.rb, line 59 def can_overflow? synchronize { ns_limited_queue? } end
@!macro thread_pool_executor_attr_reader_completed_task_count
# File lib/concurrent/executor/ruby_thread_pool_executor.rb, line 54 def completed_task_count synchronize { @completed_task_count } end
@!macro thread_pool_executor_attr_reader_largest_length
# File lib/concurrent/executor/ruby_thread_pool_executor.rb, line 44 def largest_length synchronize { @largest_length } end
@!macro thread_pool_executor_attr_reader_length
# File lib/concurrent/executor/ruby_thread_pool_executor.rb, line 64 def length synchronize { @pool.length } end
@!macro thread_pool_executor_attr_reader_queue_length
# File lib/concurrent/executor/ruby_thread_pool_executor.rb, line 69 def queue_length synchronize { @queue.length } end
@!visibility private
# File lib/concurrent/executor/ruby_thread_pool_executor.rb, line 90 def ready_worker(worker) synchronize { ns_ready_worker worker } end
@!macro thread_pool_executor_attr_reader_remaining_capacity
# File lib/concurrent/executor/ruby_thread_pool_executor.rb, line 74 def remaining_capacity synchronize do if ns_limited_queue? @max_queue - @queue.length else -1 end end end
@!visibility private
# File lib/concurrent/executor/ruby_thread_pool_executor.rb, line 85 def remove_busy_worker(worker) synchronize { ns_remove_busy_worker worker } end
@!macro thread_pool_executor_attr_reader_scheduled_task_count
# File lib/concurrent/executor/ruby_thread_pool_executor.rb, line 49 def scheduled_task_count synchronize { @scheduled_task_count } end
@!visibility private
# File lib/concurrent/executor/ruby_thread_pool_executor.rb, line 100 def worker_died(worker) synchronize { ns_worker_died worker } end
Generated with the Darkfish Rdoc Generator 2.