class Concurrent::DependencyCounter

def initialize(count, &block)
  @counter = AtomicFixnum.new(count)
  @block = block
end

def update(time, value, reason)
  if @counter.decrement == 0
    @block.call
  end
end