Class: MaybeLater::ThreadPool

Inherits:

Object

• Object
• MaybeLater::ThreadPool

Defined in:

lib/maybe_later/thread_pool.rb

Class Method Summary

• .instance ⇒ Object

Instance Method Summary

• #initialize ⇒ ThreadPool constructor

  The only time this is invoked by the gem will be when an Async task runs As a result, the max thread config will be locked after responding to the first relevant request, since the pool will have been created.

• #run(callback) ⇒ Object

Constructor Details

#initialize ⇒ ThreadPool

The only time this is invoked by the gem will be when an Async task runs As a result, the max thread config will be locked after responding to the first relevant request, since the pool will have been created

# File 'lib/maybe_later/thread_pool.rb', line 10

def initialize
  @pool = Concurrent::FixedThreadPool.new(MaybeLater.config.max_threads)
  @invokes_callback = InvokesCallback.new
end

Class Method Details

.instance ⇒ Object

# File 'lib/maybe_later/thread_pool.rb', line 3

def self.instance
  @instance ||= new
end

Instance Method Details

#run(callback) ⇒ Object

# File 'lib/maybe_later/thread_pool.rb', line 15

def run(callback)
  @pool.post do
    @invokes_callback.call(callback)
  end
end