Thread Pool'd threaded_scan Method

thread_poold_port_scanner_5.rb

# previous code...

class PortScanner 
  
  # previous code ...
  
  def threaded_scan(threads: 10)
    pool = Queue.new
    # Spool up jobs in a queue with its own thread.
    Thread.new do
      @ports.each do |port|
        connect_to port do |job|
          pool << job
        end
      end
      # Spool up one EndOfOp per Thread
      threads.times do
        pool << EndOfOp.new
      end
    end
    # Spool through those jobs.
    threads.times do
      Thread.new do
        while job = pool.pop
          break if job.instance_of? EndOfOp
          job.call
        end
      end
    end
    # Wait for the threads to finnish spool'n through the queue.
    Thread.list.each{ |t| t.join unless t == Thread.current }
  end
  
end