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