class Fluent::Counter::CleanupThread

def initialize(store, mutex_hash, mutex)
  @store = store
  @mutex_hash = mutex_hash
  @mutex = mutex
  @thread = nil
  @running = false
end