class Concurrent::RubyThreadPoolExecutor

def queue_length

Returns:
  • (Integer) - the queue_length
def queue_length
  mutex.synchronize{ running? ? @queue.length : 0 }
end