Contents

require 'common/ext/stdout'
require 'stringio'
require 'thread'
require 'monitor' # this should fix a missing require in concurrent gem
require 'concurrent/atomic/mutex_semaphore'

module Bake
  module Multithread

    class Jobs

      def self.incThread
        @@semaphore.acquire
      end
      def self.decThread
        @@semaphore.release
      end
      def self.init_semaphore
        @@semaphore = ::Concurrent::MutexSemaphore.new(Bake.options.threads)
      end

      def initialize(jobs, &block)
        nr_of_threads = [Bake.options.threads, jobs.length].min
        @jobs = jobs
        @threads = []
        nr_of_threads.times do
          @threads << ::Thread.new(Thread.current[:stdout]) do |outStr|
            Thread.current[:stdout] = outStr
            begin
              Jobs.incThread()
              block.call(self)
            ensure
              Jobs.decThread()
            end
          end
        end
      end

      def failed
        @failed ||= false
      end
      def set_failed
        @failed = true
      end

      def get_next_or_nil
        the_next = nil
        mutex.synchronize {
          the_next = @jobs.shift
        }
        the_next
      end
      def join
        @threads.each{|t| while not t.join(2) do end}
      end
      def mutex
        @mutex ||= Mutex.new
      end
    end

  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
bake-toolkit-2.46.0	lib/multithread/job.rb
bake-toolkit-2.45.0	lib/multithread/job.rb
bake-toolkit-2.44.1	lib/multithread/job.rb
bake-toolkit-2.44.0	lib/multithread/job.rb