class Thread
Public Instance Methods
process_events()
click to toggle source
# File lib/roby/support.rb, line 90 def process_events @msg_queue ||= Queue.new loop do object, name, args, block = *@msg_queue.deq(true) object.send(name, *args, &block) end rescue ThreadError end
send_to(object, name, *args, &prc)
click to toggle source
# File lib/roby/support.rb, line 82 def send_to(object, name, *args, &prc) if Thread.current == self object.send(name, *args, &prc) else @msg_queue ||= Queue.new @msg_queue << [ object, name, args, prc ] end end