logstash-core/lib/logstash/util/wrapped_acked_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
        if @queue.closed?
          raise QueueClosedError.new("Attempt to take a batch from a closed AckedQueue")
        end
        batch = new_batch
        batch.read_next
        start_metrics(batch)
        batch
      end
def read_batch if @queue . closed? raise QueueClosedError . new ( "Attempt to take a batch from a closed AckedQueue" ) end batch = new_batch batch . read_next 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 .