Class: FastlyNsq::PriorityThreadPool

Inherits:

Concurrent::ThreadPoolExecutor

• Object
• Concurrent::ThreadPoolExecutor
• FastlyNsq::PriorityThreadPool

Defined in:

lib/fastly_nsq/priority_thread_pool.rb

Instance Method Summary

• #initialize ⇒ PriorityThreadPool constructor

  A new instance of PriorityThreadPool.

Constructor Details

#initialize ⇒ PriorityThreadPool

Returns a new instance of PriorityThreadPool.

# File 'lib/fastly_nsq/priority_thread_pool.rb', line 6

def initialize(*)
  super

  @queue = FastlyNsq::PriorityQueue.new(:max)
end