› Async::Container › Source › Async › Container

module Container

Nested

Definitions

def self.fork?

Whether the underlying process supports fork.

Signature
returns　Boolean

Implementation

 
def self.fork?
	::Process.respond_to?(:fork) && ::Process.respond_to?(:setpgid)
end

def self.best_container_class

Determins the best container class based on the underlying Ruby implementation. Some platforms, including JRuby, don't support fork. Applications which just want a reasonable default can use this method.

Signature
returns　Class

Implementation

 
def self.best_container_class
	if fork?
		return Forked
	else
		return Threaded
	end
end

def self.new(*arguments, **options)

Create an instance of the best container class.

Signature
returns　Generic

Typically an instance of either class Async::Container::Forked or class Async::Container::Threaded containers.

Implementation

 
def self.new(*arguments, **options)
	best_container_class.new(*arguments, **options)
end

ASYNC_CONTAINER_PROCESSOR_COUNT = 'ASYNC_CONTAINER_PROCESSOR_COUNT'

An environment variable key to override .processor_count.

def self.processor_count(env = ENV)

The processor count which may be used for the default number of container threads/processes. You can override the value provided by the system by specifying the ASYNC_CONTAINER_PROCESSOR_COUNT environment variable.

Signature
returns　Integer

The number of hardware processors which can run threads/processes simultaneously.

raises　RuntimeError

If the process count is invalid.

Implementation

 
def self.processor_count(env = ENV)
	count = env.fetch(ASYNC_CONTAINER_PROCESSOR_COUNT) do
		Etc.nprocessors rescue 1
	end.to_i
	
	if count < 1
		raise RuntimeError, "Invalid processor count #{count}!"
	end
	
	return count
end