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