Class: Thread::Process

Inherits:
Object
  • Object
show all
Defined in:
lib/thread/process.rb

Overview

A process should only interact with the outside through messages, it still uses a thread, but it should make it safer to use than sharing and locks.

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(&block) ⇒ Process

Create a new process executing the block.



33
34
35
36
37
38
39
40
41
 
# File 'lib/thread/process.rb', line 33

def initialize(&block)
	@channel = Thread::Channel.new

	Thread.new {
		instance_eval(&block)

		@channel = nil
	}
end

Class Method Details

.[](name) ⇒ Object 



28
29
30
 
# File 'lib/thread/process.rb', line 28

def self.[](name)
	all[name]
end

.all ⇒ Object 



16
17
18
 
# File 'lib/thread/process.rb', line 16

def self.all
	@@processes ||= {}
end

.register(name, process) ⇒ Object 



20
21
22
 
# File 'lib/thread/process.rb', line 20

def self.register(name, process)
	all[name] = process
end

.unregister(name) ⇒ Object 



24
25
26
 
# File 'lib/thread/process.rb', line 24

def self.unregister(name)
	all.delete(name)
end

Instance Method Details

#send(what) ⇒ Object Also known as: <<

Send a message to the process.



44
45
46
47
48
49
50
51
52
 
# File 'lib/thread/process.rb', line 44

def send(what)
	unless @channel
		raise RuntimeError, 'the process has terminated'
	end

	@channel.send(what)

	self
end