Method: Thread::Channel#receive

Defined in:
lib/thread/channel.rb

#receive(&block) ⇒ Object

Receive a message, if there are none the call blocks until there’s one.

If a block is passed, it’s used as guard to match to a message.



50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
 
# File 'lib/thread/channel.rb', line 50

def receive(&block)
	message = nil
	found   = false

	if block
		until found
			@mutex.synchronize {
				if index = @messages.find_index(&block)
					message = @messages.delete_at(index)
					found   = true
				else
					cond.wait @mutex
				end
			}
		end
	else
		until found
			@mutex.synchronize {
				if @messages.empty?
					cond.wait @mutex
				end

				unless @messages.empty?
					message = @messages.shift
					found   = true
				end
			}
		end
	end

	message
end