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 start_metrics(batch)
        thread = Thread.current
        @mutex.lock
        begin
          @inflight_batches[thread] = batch
        ensure
          @mutex.unlock
        end
        @inflight_clocks[thread] = java.lang.System.nano_time
      end
def start_metrics ( batch ) thread = Thread . current @mutex . lock begin @inflight_batches [ thread ] = batch ensure @mutex . unlock end @inflight_clocks [ thread ] = java . lang . System . nano_time 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 .
batch
<not_specific>