Class: Bob::BackgroundEngines::Threaded

Inherits:

Object

• Object
• Bob::BackgroundEngines::Threaded

Defined in:

lib/bob/background_engines/threaded.rb

Defined Under Namespace

Classes: ThreadPool

Instance Method Summary

• #call(job) ⇒ Object
• #initialize(pool_size = 2) ⇒ Threaded constructor

  A new instance of Threaded.

• #njobs ⇒ Object
• #wait! ⇒ Object

Constructor Details

#initialize(pool_size = 2) ⇒ Threaded

Returns a new instance of Threaded.

# File 'lib/bob/background_engines/threaded.rb', line 7

def initialize(pool_size = 2)
  @pool = ThreadPool.new(pool_size)
end

Instance Method Details

#call(job) ⇒ Object

# File 'lib/bob/background_engines/threaded.rb', line 11

def call(job)
  @pool << job
end

#njobs ⇒ Object

# File 'lib/bob/background_engines/threaded.rb', line 15

def njobs
  @pool.njobs
end

#wait! ⇒ Object

# File 'lib/bob/background_engines/threaded.rb', line 19

def wait!
  Thread.pass until @pool.njobs == 0
end