Sha256: 778b381475bcb850e9631c1aed689a355dbbbafe47305b37179c7244d01a13ea
Contents?: true
Size: 502 Bytes
Versions: 26
Compression:
Stored size: 502 Bytes
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
26 entries across 26 versions & 1 rubygems