Contents

module Sideband
  class Thread

    attr_reader :thread

    def initialize(manager)
      @manager = manager
      @thread = ::Thread.new do
        while work = @manager.queue.pop
          exit if work.nil?
          
          begin
            work.call
          rescue Exception
            # Sideband will ignore all Exceptions, 
            # better to handle in your workers.
          end
        end
      end
    end

    def join
      thread.join
    end

    def kill
      thread.kill
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
sideband-1.0.1	lib/sideband/thread.rb
sideband-1.0.0	lib/sideband/thread.rb