github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 14:47:19 -04:00
Code Issues Projects Releases Packages Wiki Activity

MINOR: Flatten Pipeline Worker Threads

Browse source 
Fixes #7836
This commit is contained in:
Armin 2017-07-28 10:28:49 +02:00 • committed by Armin Braun
parent 97a5d76ba4
commit 11754001e5
1 changed files with 4 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

7
logstash-core/lib/logstash/pipeline.rb
View file

@ -415,10 +415,11 @@ module LogStash; class Pipeline < BasePipeline
end
pipeline_workers.times do |t|
@worker_threads << Thread.new do
Util.set_thread_name("[#{pipeline_id}]>worker#{t}")
worker_loop(batch_size, batch_delay)
thread = Thread.new(batch_size, batch_delay, self) do |_b_size, _b_delay, _pipeline|
_pipeline.worker_loop(_b_size, _b_delay)
end
thread.name="[#{pipeline_id}]>worker#{t}"
@worker_threads << thread
end
# inputs should be started last, after all workers