class Fluent::Counter::CleanupThread

def stop
  return unless @running
  @running = false
  begin
    # Avoid waiting CLEANUP_INTERVAL
    Timeout.timeout(1) do
      @thread.join
    end
  rescue Timeout::Error
    @thread.kill
  end
end