## mark a section (Learn more)

require 'thread' # Used for Thread::Queue that synchronizes between main thread and job queue require 'glib2' class AsyncRunner def initialize(sync_client) @sync_client = sync_client @call_queue = Queue.new start end def start @working_thread = Thread.new do loop do call = @call_queue.deq # Will block until there is a queue to pop begin ret_val = @sync_client.send(call[0], *call[1]) GLib::Idle.add { call[2].call(ret_val); false } rescue => exception GLib::Idle.add { raise_exception(exception); break; false} end end end end def raise_exception raise exception.class, "While AsyncRunner called method '#{call[0]}' #{exception}" end def stop unless @working_thread.nil? @working_thread.exit end end def method_missing(method_id, *arguments, &block) call = [method_id, arguments, block] @call_queue.enq(call) end def respond_to?(n) @sync_client.respond_to?(n) end end

This paste will be private.