class Parapool::Job

Attributes

param[RW]
result[RW]

Public Class Methods

new(param, sync, &block) click to toggle source
# File lib/parapool/job.rb, line 7
def initialize(param, sync, &block)
  raise Parapool::Error, 'must be called with a block' unless block_given?

  @param = param
  @sync = sync
  @block = block
end

Public Instance Methods

run() click to toggle source
# File lib/parapool/job.rb, line 15
def run
  @result = @block.call(param) rescue $!

  @sync.count

  @result
end