vendor/bundle/ruby/1.8/gems/work_queue-1.0.0/lib/work_queue.rb
def enqueue_p(proc, *args)
    @tasks << [proc,args]
    spawn_thread
    self
  end
##
# Schedules the given Proc for future execution by a worker thread.
# If there is no space left in the queue, waits until space becomes available.
#
#  wq = WorkQueue.new(1)
#  wq.enqueue_p(Proc.new {})
#
Schedules the given Proc for future execution by a worker thread.
If there is no space left in the queue, waits until space becomes available.


Schedules the given Proc for future execution by a worker thread . If there is no space left in the queue waits until space becomes available .
def enqueue_p(proc, *args)
    @tasks << [proc,args]
    spawn_thread
    self
  end
def enqueue_p ( proc , * args ) @tasks << [ proc , args ] spawn_thread self end
Schedules the given Proc for future execution by a worker thread.
Schedules the given Proc for future execution by a worker thread .
proc
args