Bug #5258 » patch.diff
| lib/thread.rb | ||
|---|---|---|
|
@mutex.synchronize{
|
||
|
while true
|
||
|
break if @que.length < @max
|
||
|
@queue_wait.push Thread.current
|
||
|
@queue_wait.push Thread.current unless @queue_wait.include?(Thread.current)
|
||
|
@mutex.sleep
|
||
|
end
|
||