Contents

class ThreadWorker
  attr_reader :work_done

  def initialize(blackboard, expected_work)
    @blackboard, @expected_work = blackboard, expected_work
    @thread = Thread.new {run}
  end

  def wait_until_done
    Timeout.timeout(5) {@thread.join}
    @thread.kill if @thread.alive?
  end

  def run
    @work_done = 0
    until @work_done >= @expected_work
      Thread.pass
      work = @blackboard.take_work
      if work
        @blackboard.write_result work.run 
        @work_done += 1
      end
    end
  end
end

Version data entries

6 entries across 6 versions & 2 rubygems

Version	Path
jperkins-deep_test-1.2.2	spec/thread_worker.rb
jstorimer-deep-test-1.4.0	spec/thread_worker.rb
jstorimer-deep-test-1.3.0	spec/thread_worker.rb
jstorimer-deep-test-1.2.0	spec/thread_worker.rb
jstorimer-deep-test-1.1.0	spec/thread_worker.rb
jstorimer-deep-test-1.0.0	spec/thread_worker.rb