in lib/logstash-docket/util/threadsafe_index.rb [25:37]
def fetch(key)
@index.fetch(key) do
@mutex.synchronize do
return @index.fetch(key) if @index.include?(key)
@index.store(key, @generator.call(key))
end
end
end