サイズの最大値を指定できる Queue です。
[ruby-list:283]より。q をサイズ 1 の SizedQueue オブジェクトに
することによって、入力される行と出力される行が同じ順序になります。
q = [] にすると入力と違った順序で行が出力されます。
require 'thread'
q = SizedQueue.new(1)
th = Thread.start {
while line = q.pop
print line
end
}
while l = gets
q.push(l)
end
q.push(l)
th.join
maxmax= nqueue の最大サイズを設定します。
push(obj)queue に obj を追加します。
queue のサイズが max に達している場合は、 queue のサイズが max より小さくなるまで他のスレッドに実行を譲ります。その後、 queue に obj を追加します。
あとは Queue#push と同じです。
popqueue からひとつ値を取り出します。 queue に push しようと待っているスレッドがあれば、実行を再開させます。
あとは Queue#pop と同じです。