class ConcurrentWorker::WorkerPool::ReadyWorkerQueue

Public Class Methods

new() click to toggle source
Calls superclass method
# File lib/concurrent_worker/workerpool.rb, line 6
def initialize
  super()
  @m = Mutex.new
end

Public Instance Methods

pop() click to toggle source
# File lib/concurrent_worker/workerpool.rb, line 15
def pop
  @m.synchronize do
    queued = []
    queued.push(super_pop) until empty?
    queued.sort_by{ |w| w.req_counter.size }.each{ |w| super_push(w) }
  end
  super_pop
end
Also aliased as: super_pop
push(arg) click to toggle source
# File lib/concurrent_worker/workerpool.rb, line 10
def push(arg)
  @m.synchronize do
    super_push(arg)
  end
end
Also aliased as: super_push
super_pop()
Alias for: pop
super_push(arg)
Alias for: push