pop(*args)
public
Retrieves data from the queue and runs a waiting thread, if any.
Show source
def pop(*args)
retval = super
@mutex.synchronize {
if @que.length < @max
begin
t = @queue_wait.shift
t.wakeup if t
rescue ThreadError
retry
end
end
}
retval
end
RSpec
Ruby on Rails
Ruby
= private
= protected
