Contents

# frozen_string_literal: true

module Wayfarer
  GC = Struct.new(:job) do
    def run
      task = job.task

      return unless task.counter.decrement <= 0

      task.barrier.reset!
      task.counter.reset!
      job.run_callbacks(:batch)
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
wayfarer-0.4.3	lib/wayfarer/gc.rb
wayfarer-0.4.2	lib/wayfarer/gc.rb
wayfarer-0.4.1	lib/wayfarer/gc.rb