Contents

require 'thread'
require 'set'

Thread.abort_on_exception = true

module Xi
  class Clock
    DEFAULT_CPS  = 1.0
    INTERVAL_SEC = 10 / 1000.0

    attr_reader :init_ts, :latency

    def initialize(cps: DEFAULT_CPS)
      @mutex = Mutex.new
      @cps = cps
      @playing = true
      @streams = [].to_set
      @init_ts = Time.now.to_f
      @latency = 0.0
      @play_thread = Thread.new { thread_routine }
    end

    def subscribe(stream)
      @mutex.synchronize { @streams << stream }
    end

    def unsubscribe(stream)
      @mutex.synchronize { @streams.delete(stream) }
    end

    def cps
      @mutex.synchronize { @cps }
    end

    def cps=(new_cps)
      @mutex.synchronize { @cps = new_cps.to_f }
    end

    def latency=(new_latency)
      @latency = new_latency.to_f
    end

    def playing?
      @mutex.synchronize { @playing }
    end

    def stopped?
      !playing?
    end

    def play
      @mutex.synchronize { @playing = true }
      self
    end
    alias_method :start, :play

    def stop
      @mutex.synchronize { @playing = false }
      self
    end
    alias_method :pause, :play

    def seconds_per_cycle
      @mutex.synchronize { 1.0 / @cps }
    end

    def inspect
      "#<#{self.class.name}:#{"0x%014x" % object_id} " \
        "cps=#{cps.inspect} #{playing? ? :playing : :stopped}>"
    end

    private

    def thread_routine
      loop do
        do_tick
        sleep INTERVAL_SEC
      end
    end

    def do_tick
      return unless playing?
      now = Time.now.to_f - @init_ts + @latency
      cps = self.cps
      @streams.each { |s| s.notify(now, cps) }
    rescue => err
      error(err)
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
xi-lang-0.1.4	lib/xi/clock.rb