Sha256: 6df99fe373d778f5aecc6583ae7efed05687dded08f9ddc63bb833ce0f92ad24

Contents?: true

Size: 677 Bytes

Versions: 7

Compression:

Stored size: 677 Bytes

Contents

# frozen_string_literal: true

# Released under the MIT License.
# Copyright, 2017-2022, by Samuel Williams.

require_relative 'generic'
require_relative 'process'

module Async
	module Container
		# A multi-process container which uses {Process.fork}.
		class Forked < Generic
			# Indicates that this is a multi-process container.
			def self.multiprocess?
				true
			end
			
			# Start a named child process and execute the provided block in it.
			# @parameter name [String] The name (title) of the child process.
			# @parameter block [Proc] The block to execute in the child process.
			def start(name, &block)
				Process.fork(name: name, &block)
			end
		end
	end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version Path
async-container-0.18.3 lib/async/container/forked.rb
async-container-0.18.2 lib/async/container/forked.rb
async-container-0.18.1 lib/async/container/forked.rb
async-container-0.18.0 lib/async/container/forked.rb
async-container-0.17.1 lib/async/container/forked.rb
async-container-0.17.0 lib/async/container/forked.rb
async-container-0.16.13 lib/async/container/forked.rb