Contents

class BasicJob
  class_attribute :results
  self.results = Concurrent::Array.new

  def initialize(some_param: nil, sleep_time: 1)
    @some_param = some_param
    @sleep_time = sleep_time
  end

  def perform
    results << @some_param
    sleep @sleep_time
  end
end

class DbConnectionTestJob
  class_attribute :db_connections
  self.db_connections = Concurrent::Array.new

  def perform
    db_connections << ActiveRecord::Base.connection.object_id
  end
end

class DummyRailsOpsOp
  class_attribute :results
  self.results = Concurrent::Array.new

  def self.run!(params = {})
    new(params).run!
  end

  def initialize(params = {})
    @params = params
  end

  def run!
    perform
  end

  private

  def perform
    results << @params
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
workhorse-0.1.0	test/lib/jobs.rb
workhorse-0.0.3	test/lib/jobs.rb
workhorse-0.0.2	test/lib/jobs.rb