push(obj)
public
Pushes obj to the queue. If there is no space left in the queue,
waits until space becomes available.
Show source
def push(obj)
@mutex.synchronize{
while true
break if @que.length < @max
@queue_wait.push Thread.current
@mutex.sleep
end
@que.push obj
begin
t = @waiting.shift
t.wakeup if t
rescue ThreadError
retry
end
}
end
RSpec
Ruby on Rails
Ruby
= private
= protected
