multi fiber jobs

jobs.cr

class Job
  def self.create(number_of_jobs : Int32) : Array(Job)
    jobs = [] of Job
    inbound = Channel(String).new
    outbound = Channel(String).new

    number_of_jobs.times do |_|
      job = Job.new(inbound, outbound)
      job.run
      jobs << job
    end
    jobs
  end

  @message_pool = [] of String

  def initialize(@inbound : Channel(String), @outbound : Channel(String))
  end

  def task(message : String)
    response("#{message}-ok")
  end

  def run
    spawn do
      loop do
        next unless message = @inbound.receive

        task(message)
      end
    end
    wait_fiber
  end

  def wait_fiber
    spawn do
      loop do
        sleep 0.01

        next unless message = @message_pool.shift?
        @inbound.send(message)
      end
    end
  end

  def exec(message : String? = nil)
    @message_pool << message
  end

  def response(message : String)
    @outbound.send(message)
  end

  def receive : String?
    return nil unless message = @outbound.receive

    message
  end
end

jobs = Job.create(10)

jobs.each_with_index do |w, i|
  w.exec(i.to_s)
end

jobs.each do |w|
  puts w.receive
end