Class: Wrest::AsyncRequest::ThreadPool

Inherits:

Object

• Object
• Wrest::AsyncRequest::ThreadPool

Defined in:

lib/wrest/async_request/thread_pool.rb

Instance Method Summary

• #execute_eventually(request) ⇒ Object
• #initialize(number_of_threads) ⇒ ThreadPool constructor

  A new instance of ThreadPool.

• #join_pool_threads! ⇒ Object

Constructor Details

#initialize(number_of_threads) ⇒ ThreadPool

Returns a new instance of ThreadPool.

# File 'lib/wrest/async_request/thread_pool.rb', line 15

def initialize(number_of_threads)
  @pool = Concurrent::FixedThreadPool.new(number_of_threads)
end

Instance Method Details

#execute_eventually(request) ⇒ Object

# File 'lib/wrest/async_request/thread_pool.rb', line 19

def execute_eventually(request)
  @pool.post { request.invoke }
  nil
end

#join_pool_threads! ⇒ Object

# File 'lib/wrest/async_request/thread_pool.rb', line 24

def join_pool_threads!
  @pool.wait_for_termination
end