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

PERFORMANCE: Remve needless locking on batch reads

Browse source 
Fixes #7623
This commit is contained in:
Armin 2017-07-09 17:49:13 +02:00 • committed by Armin Braun
parent 96ff365997
commit dfb423a60f
1 changed files with 2 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

9
logstash-core/lib/logstash/util/wrapped_synchronous_queue.rb
View file

@ -6,7 +6,7 @@ module LogStash; module Util
java_import java.util.concurrent.TimeUnit java_import java.util.concurrent.TimeUnit
def initialize def initialize
@queue = java.util.concurrent.SynchronousQueue.new @queue = SynchronousQueue.new
end end
# Push an object to the queue if the queue is full # Push an object to the queue if the queue is full
@ -103,12 +103,7 @@ module LogStash; module Util
def read_batch def read_batch
batch = new_batch batch = new_batch
@mutex.lock batch.read_next
begin
batch.read_next
ensure
@mutex.unlock
end
start_metrics(batch) start_metrics(batch)
batch batch
end end