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 empty?
        @mutex.lock
        begin
          @queue.is_empty?
        ensure
          @mutex.unlock
        end
      end
def empty? @mutex . lock begin @queue . is_empty? ensure @mutex . unlock end 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 .