Contents

# frozen_string_literal: true

require "etc"

class Quickdraw::Cluster
	def self.call(n = Etc.nprocessors, &)
		spawn(n, &).wait
	end

	def self.spawn(n = Etc.nprocessors, &block)
	  new.tap do |cluster|
			n.times { cluster.fork(&block) }
		end
	end

	def initialize
		@workers = []
	end

	def fork(&)
		@workers << Quickdraw::Worker.fork(&)
	end

	def wait
		@workers.map(&:wait)
	end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
quickdraw-0.1.0	lib/quickdraw/cluster.rb