Contents

module Lux::DelayedJob::Memory
  extend self

  @@JOBS = []

  def push(data)
    @@JOBS.push data
    Thread.new { true while Lux::DelayedJob.pop }
  end

  def pop
    @@JOBS.shift
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
lux-fw-0.2.3	./lib/lux/delayed_job/lib/memory.rb
lux-fw-0.2.1	./lib/lux/delayed_job/lib/memory.rb
lux-fw-0.1.35	./lib/lux/delayed_job/lib/memory.rb
lux-fw-0.1.17	./lib/lux/delayed_job/lib/memory.rb