voicemeeter-rb/lib/voicemeeter/worker.rb

65 lines
1.8 KiB
Ruby

module Voicemeeter
module Worker
include Logging
private
def init_producer(que)
@producer = Thread.new do
Thread.current.name = "producer"
Thread.current[:running] = true
while Thread.current[:running]
que << :pdirty if event.pdirty
que << :mdirty if event.mdirty
que << :midi if event.midi
que << :ldirty if event.ldirty
sleep(@ratelimit)
end
logger.debug "closing #{Thread.current.name} thread"
que << Thread.current[:running]
end
end
def init_worker(que)
logger.info "Listening for #{event.get.join(", ")} events"
cache[:strip_level], cache[:bus_level] = _get_levels
cache[:strip_comp] = Array.new(kind.num_strip_levels, false)
cache[:bus_comp] = Array.new(kind.num_bus_levels, false)
Thread.new do
Thread.current.name = "worker"
while (event = que.pop)
fire :pdirty if event == :pdirty && pdirty?
fire :mdirty if event == :mdirty && mdirty?
fire :midi if event == :midi && get_midi_message
if event == :ldirty && ldirty?
cache[:strip_comp] = cache[:strip_level].zip(cache[:strip_buf]).map { |a, b| a != b }
cache[:bus_comp] = cache[:bus_level].zip(cache[:bus_buf]).map { |a, b| a != b }
cache[:strip_level] = cache[:strip_buf]
cache[:bus_level] = cache[:bus_buf]
fire :ldirty
end
end
logger.debug "closing #{Thread.current.name} thread"
end
end
public
def running?
@producer&.alive?
end
def init_event_threads
que = Queue.new
init_worker(que) and init_producer(que)
end
def end_event_threads
if running?
@producer[:running] = false
@producer.join
end
end
end
end