Patch for high cpu load issue
This commit is contained in:
@@ -273,10 +273,13 @@ private
|
|||||||
Thread.new do
|
Thread.new do
|
||||||
begin
|
begin
|
||||||
loop do
|
loop do
|
||||||
|
wrote_data = false
|
||||||
(IO.select(@readers.values).first || []).each do |reader|
|
(IO.select(@readers.values).first || []).each do |reader|
|
||||||
data = reader.gets
|
data = reader.gets
|
||||||
|
wrote_data = !data.nil?
|
||||||
output_with_mutex name_for(@readers.invert[reader]), data
|
output_with_mutex name_for(@readers.invert[reader]), data
|
||||||
end
|
end
|
||||||
|
sleep(1) unless wrote_data
|
||||||
end
|
end
|
||||||
rescue Exception => ex
|
rescue Exception => ex
|
||||||
puts ex.message
|
puts ex.message
|
||||||
|
|||||||
Reference in New Issue
Block a user