Contents

module Lux::DelayedJob::Memory
  extend self

  @jobs = []

  def push data
    @jobs.push data

    # delayed jobs in memory are resolved asap
    Thread.new { true while pop }
  end

  def pop
    @jobs.shift
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
lux-fw-0.5.37	./lib/lux/delayed_job/lib/memory.rb
lux-fw-0.5.36	./lib/lux/delayed_job/lib/memory.rb
lux-fw-0.5.35	./lib/lux/delayed_job/lib/memory.rb
lux-fw-0.5.34	./lib/lux/delayed_job/lib/memory.rb
lux-fw-0.5.33	./lib/lux/delayed_job/lib/memory.rb
lux-fw-0.5.32	./lib/lux/delayed_job/lib/memory.rb