Contents

module LogStash
  module Inputs
    module Azure
      class NamedThreadFactory
        include java.util.concurrent.ThreadFactory
        java_import java.util.concurrent.atomic.AtomicInteger

        def initialize(name, id)
          @name = name
          @id = id
          @counter = AtomicInteger.new(-1)
        end

        def newThread(runnable)
          java.lang.Thread.new(runnable, @name + "-" + @counter.increment_and_get.to_s + "-" + @id.to_s)
        end
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
logstash-input-azureiothub-0.1.15	lib/logstash/inputs/named_thread_factory.rb