Method: Thread::Channel#initialize

Defined in:
lib/thread/channel.rb

#initialize(messages = [], &block) ⇒ Channel

Create a channel with optional initial messages and optional channel guard.



19
20
21
22
23
24
25
26
27
 
# File 'lib/thread/channel.rb', line 19

def initialize(messages = [], &block)
  @messages = []
  @mutex    = Mutex.new
  @check    = block

  messages.each {|o|
    send o
  }
end