Contents

# frozen_string_literal: true

module Mutant
  module Parallel
    class Worker
      include Adamantium::Flat, Anima.new(
        :processor,
        :var_active_jobs,
        :var_final,
        :var_running,
        :var_sink,
        :var_source
      )

      private(*anima.attribute_names)

      # Run worker payload
      #
      # @return [self]
      #
      # ignore :reek:TooManyStatements
      def call
        loop do
          job = next_job or break

          job_start(job)

          result = processor.call(job.payload)

          job_done(job)

          break if add_result(result)
        end

        finalize

        self
      end

    private

      # Next job, if any
      #
      # @return [Job, nil]
      def next_job
        var_source.with do |source|
          source.next if source.next?
        end
      end

      # Add result
      #
      # @param [Object] result
      #
      # @return [Boolean]
      def add_result(result)
        var_sink.with do |sink|
          sink.result(result)
          sink.stop?
        end
      end

      # Register job to be started
      #
      # @param [Job] job
      #
      # @return [undefined]
      def job_start(job)
        var_active_jobs.with do |active_jobs|
          active_jobs << job
        end
      end

      # Register job to be done
      #
      # @param [Job] job
      # @param [Object] result
      #
      # @return [undefined]
      def job_done(job)
        var_active_jobs.with do |active_jobs|
          active_jobs.delete(job)
        end
      end

      # Finalize worker
      #
      # @return [undefined]
      def finalize
        var_final.put(nil) if var_running.modify(&:pred).zero?
      end

    end # Worker
  end # Parallel
end # Mutant

Version data entries

9 entries across 9 versions & 1 rubygems

Version	Path
mutant-0.9.8	lib/mutant/parallel/worker.rb
mutant-0.9.7	lib/mutant/parallel/worker.rb
mutant-0.9.6	lib/mutant/parallel/worker.rb
mutant-0.9.5	lib/mutant/parallel/worker.rb
mutant-0.9.4	lib/mutant/parallel/worker.rb
mutant-0.9.3	lib/mutant/parallel/worker.rb
mutant-0.9.2	lib/mutant/parallel/worker.rb
mutant-0.9.1	lib/mutant/parallel/worker.rb
mutant-0.9.0	lib/mutant/parallel/worker.rb