Skip to content

Instantly share code, notes, and snippets.

require 'thread'
class Actor
def initialize(send_queue, recv_queue)
@send_queue = send_queue
@recv_queue = recv_queue
end
def send(sym, *args)
@send_queue.push([sym,*args])