# Ruby 3.0.1 で動作確認済み
class Ticker
  def initialize
    # non blocking readをするためのRactor生成クラス。クラス・モジュールはRactor間でSharableなのでこうした。
    @filler = FillerMaker.make
    # ゲーム時間を生成するRactorをつくっておく。
    @ticking = make_ticking
  end

  # ゲーム時間の加速、遅延を受け付けるメソッド。<<は`Ractor#send`のAlias。
  def change_speed(speed)
    raise unless speed.is_a?(Numeric)
    @ticking << speed
  end

  # Non blocking read. Ractor.currentにメッセージが届いていればそれを読むし、でなければ'noop'を返すためだけのfillerから読む。
  # いつ呼び出すかによってメッセージがどれくらい溜まっているかは可変なので、whileなどを使って実際には使うイメージ。
  def reads
    _sender, yielded = Ractor.select(Ractor.current, @filler.tap { |f| f << 'noop' })
    yielded
  end
  
  # 主にDebug/test用のblocking read。
  def blocking_reads
    Ractor.current.take
  end

  private

  module FillerMaker
    def make
      # https://github.com/ruby/ruby/blob/master/doc/ractor.mdではPipeとなっている実装。入れた瞬間、入れたものを返すRactor。
      Ractor.new do
        loop do
          Ractor.yield Ractor.receive
        end
      end
    end
    module_function :make
  end

  def make_ticking
    # Ractor自身はSynchronizationが内部実装されているらしい（どういう意味だろう）ので、main ractorをmessage receieverとして渡す。
    Ractor.new Ractor.current do |main|
      filler = filler_maker.make
      current_speed = 1

      elapsed = Time.now
      loop do
        # ゲームスピードの変更を受け付けるselect.
        _sender, speed = Ractor.select(Ractor.current, filler.tap { |f| f << 'noop-speed' })
        if speed.is_a?(Numeric)
          current_speed = speed
        end
        now = Time.now
        if ((now - elapsed) * current_speed) >= 3600
	  # main ractorにゲーム内発行イベントを送る
          main << [now, current_speed]
          elapsed = Time.now
        end
      end
    end
  end
end

おわり

Thread/Fiber使った方が普通そう。でもRactorを使ってみたかった（そもそもThread programming本気でしたことがない）。

Productionで運用するならRedisとかでRactorで書いた部分は実装すると思う😇 でも、Rubyだけで色々できる、という自信が今後もRubyを使い続けたいなら大事だと思う。

素直に書けたので、RactorのAPIが好きになった。
こんなことしなくてもやりたいこと書けるよ、という方はぜひコメントください。

やりたかったこと

Ruby3のRactorで書いてみた

おわり

Discussion