Implement basic actor pattern

Author: noteflakes

.github/workflows/test.yml

@@ -13,7 +13,7 @@ jobs:
       matrix:
         # macos-latest uses arm64, macos-13 uses x86
         os: [ubuntu-latest]
-        ruby: ['3.3', 'head']
+        ruby: ['3.3', '3.4', 'head']
 
     name: ${{matrix.os}}, ${{matrix.ruby}}
 

lib/uringmachine.rb

@@ -12,8 +12,8 @@ def fiber_map
     @@fiber_map
   end
 
-  def spin(value = nil, &block)
-    f = Fiber.new do |resume_value|
+  def spin(value = nil, fiber_class = Fiber, &block)
+    f = fiber_class.new do |resume_value|
       block.(resume_value)
     rescue Exception => e
       STDERR.puts "Unhandled fiber exception: #{e.inspect}"

lib/uringmachine/actor.rb

@@ -0,0 +1,52 @@
+# frozen_string_literal: true
+
+class UringMachine
+  def spin_actor(mod, *a, **k)
+    target = Object.new.extend(mod)
+    mailbox = UM::Queue.new
+    actor = spin(nil, Actor) { actor.run(self, target, mailbox) }
+    target.setup(*a, **k)
+    snooze
+    actor
+  end
+
+  class Actor < Fiber
+    def run(machine, target, mailbox)
+      @machine = machine
+      @target = target      
+      @mailbox = mailbox
+      while (msg = machine.shift(mailbox))
+        process_message(msg)
+      end
+    ensure
+      @target.teardown if @target.respond_to?(:teardown)
+    end
+
+    def cast(sym, *a, **k)
+      self << [:cast, nil, sym, a, k]
+      self
+    end
+
+    def call(sym, *a, **k)
+      self << [:call, Fiber.current, sym, a, k]
+      @machine.yield
+    end
+
+    private
+
+    def process_message(msg)
+      type, fiber, sym, args, kwargs = msg
+      case type
+      when :cast
+        @target.send(sym, *args, **kwargs)
+      when :call
+        res = @target.send(sym, *args, **kwargs)
+        @machine.schedule(fiber, res)
+      end
+    end
+
+    def <<(msg)
+      @machine.push(@mailbox, msg)
+    end
+  end
+end

test/test_actor.rb

@@ -0,0 +1,63 @@
+# frozen_string_literal: true
+
+require_relative 'helper'
+require 'socket'
+require 'uringmachine/actor'
+
+class ActorTest < UMBaseTest
+  module Counter
+    def setup
+      @count = 0      
+    end
+
+    def incr
+      @count += 1
+    end
+
+    def get
+      @count
+    end
+
+    def reset
+      @count = 0
+    end
+  end
+
+  def test_basic_actor_functionality
+    actor = @machine.spin_actor(Counter)
+    
+    assert_kind_of Fiber, actor
+
+    assert_equal 0, actor.call(:get)
+    assert_equal 1, actor.call(:incr)
+    assert_equal actor, actor.cast(:incr)
+    assert_equal 2, actor.call(:get)
+    assert_equal actor, actor.cast(:reset)
+    assert_equal 0, actor.call(:get)
+  end
+
+  module Counter2
+    def setup(count)
+      @count = count
+    end
+
+    def incr
+      @count += 1
+    end
+
+    def get
+      @count
+    end
+
+    def reset
+      @count = 0
+    end
+  end
+
+
+  def test_actor_with_args
+    actor = @machine.spin_actor(Counter2, 43)
+    
+    assert_equal 43, actor.call(:get)
+  end
+end

uringmachine.gemspec

@@ -20,8 +20,8 @@ Gem::Specification.new do |s|
   s.require_paths = ["lib"]
   s.required_ruby_version = '>= 3.3'
 
-  s.add_development_dependency  'rake-compiler',        '1.2.8'
-  s.add_development_dependency  'minitest',             '5.25.1'
+  s.add_development_dependency  'rake-compiler',        '1.2.9'
+  s.add_development_dependency  'minitest',             '5.25.4'
   s.add_development_dependency  'http_parser.rb',       '0.8.0'
   s.add_development_dependency  'benchmark-ips',        '2.14.0'
   s.add_development_dependency  'localhost',            '1.3.1'