class Concurrent::JavaThreadPoolExecutor

@!macro thread_pool_executor @!macro thread_pool_options @!visibility private

Constants

DEFAULT_MAX_POOL_SIZE: @!macro thread_pool_executor_constant_default_max_pool_size
DEFAULT_MAX_QUEUE_SIZE: @!macro thread_pool_executor_constant_default_max_queue_size
DEFAULT_MIN_POOL_SIZE: @!macro thread_pool_executor_constant_default_min_pool_size
DEFAULT_THREAD_IDLETIMEOUT: @!macro thread_pool_executor_constant_default_thread_timeout

Attributes

max_length[R]

@!macro thread_pool_executor_attr_reader_max_length

max_queue[R]

@!macro thread_pool_executor_attr_reader_max_queue

Public Class Methods

new(opts = {}) click to toggle source

@!macro thread_pool_executor_method_initialize

Calls superclass method Concurrent::JavaExecutorService.new

# File lib/concurrent/executor/java_thread_pool_executor.rb, line 31
def initialize(opts = {})
  super(opts)
end

Public Instance Methods

can_overflow?() click to toggle source

@!macro executor_service_method_can_overflow_question

# File lib/concurrent/executor/java_thread_pool_executor.rb, line 36
def can_overflow?
  @max_queue != 0
end

completed_task_count() click to toggle source

@!macro thread_pool_executor_attr_reader_completed_task_count

# File lib/concurrent/executor/java_thread_pool_executor.rb, line 66
def completed_task_count
  @executor.getCompletedTaskCount
end

idletime() click to toggle source

@!macro thread_pool_executor_attr_reader_idletime

# File lib/concurrent/executor/java_thread_pool_executor.rb, line 71
def idletime
  @executor.getKeepAliveTime(java.util.concurrent.TimeUnit::SECONDS)
end

largest_length() click to toggle source

@!macro thread_pool_executor_attr_reader_largest_length

# File lib/concurrent/executor/java_thread_pool_executor.rb, line 56
def largest_length
  @executor.getLargestPoolSize
end

length() click to toggle source

@!macro thread_pool_executor_attr_reader_length

# File lib/concurrent/executor/java_thread_pool_executor.rb, line 51
def length
  @executor.getPoolSize
end

min_length() click to toggle source

@!macro thread_pool_executor_attr_reader_min_length

# File lib/concurrent/executor/java_thread_pool_executor.rb, line 41
def min_length
  @executor.getCorePoolSize
end

queue_length() click to toggle source

@!macro thread_pool_executor_attr_reader_queue_length

# File lib/concurrent/executor/java_thread_pool_executor.rb, line 76
def queue_length
  @executor.getQueue.size
end

remaining_capacity() click to toggle source

@!macro thread_pool_executor_attr_reader_remaining_capacity

# File lib/concurrent/executor/java_thread_pool_executor.rb, line 81
def remaining_capacity
  @max_queue == 0 ? -1 : @executor.getQueue.remainingCapacity
end

running?() click to toggle source

@!macro executor_service_method_running_question

Calls superclass method Concurrent::AbstractExecutorService#running?

# File lib/concurrent/executor/java_thread_pool_executor.rb, line 86
def running?
  super && !@executor.isTerminating
end

scheduled_task_count() click to toggle source

@!macro thread_pool_executor_attr_reader_scheduled_task_count

# File lib/concurrent/executor/java_thread_pool_executor.rb, line 61
def scheduled_task_count
  @executor.getTaskCount
end