logstash-core/lib/logstash/util/wrapped_synchronous_queue.rb
# We generally only want one thread at a time able to access pop/take/poll operations
# from this queue. We also depend on this to be able to block consumers while we snapshot
# in-flight buffers
We generally only want one thread at a time able to access pop/take/poll operations
from this queue. We also depend on this to be able to block consumers while we snapshot
in-flight buffers
We generally only want one thread at a time able to access pop / take / poll operations from this queue . We also depend on this to be able to block consumers while we snapshot in - flight buffers
def read_batch
        batch = LogStash::MemoryReadBatch.new(LsQueueUtils.drain(@queue, @batch_size, @wait_for))
        start_metrics(batch)
        batch
      end
def read_batch batch = LogStash :: MemoryReadBatch . new ( LsQueueUtils . drain ( @queue , @batch_size , @wait_for ) ) start_metrics ( batch ) batch end
We generally only want one thread at a time able to access pop/take/poll operations
from this queue.
We generally only want one thread at a time able to access pop / take / poll operations from this queue .