voicemeeter-rb/lib/voicemeeter/worker.rb

64 lines
1.9 KiB
Ruby
Raw Normal View History

require_relative "logger"
2023-07-13 21:57:32 +01:00
module Voicemeeter
module Worker
2023-07-27 10:58:26 +01:00
# Event threads, provides updates to observers
include Logging
2023-07-13 21:57:32 +01:00
def init_producer(que)
2023-08-03 11:04:13 +01:00
@running = true
2023-07-13 21:57:32 +01:00
Thread.new do
2023-08-03 11:04:13 +01:00
Thread.current.name = "producer"
2023-07-14 01:46:25 +01:00
while @running
2023-07-13 21:57:32 +01:00
que << :pdirty if event.pdirty
que << :mdirty if event.mdirty
que << :midi if event.midi
que << :ldirty if event.ldirty
sleep(@ratelimit)
end
2023-08-03 11:04:13 +01:00
logger.debug "closing #{Thread.current.name} thread"
2023-07-14 01:46:25 +01:00
que << :stop
2023-07-13 21:57:32 +01:00
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)
2023-07-13 21:57:32 +01:00
Thread.new do
2023-08-03 11:04:13 +01:00
Thread.current.name = "worker"
2023-07-13 21:57:32 +01:00
loop do
e_from_que = @que.pop
2023-07-14 01:46:25 +01:00
if e_from_que == :stop
2023-08-03 11:04:13 +01:00
logger.debug "closing #{Thread.current.name} thread"
2023-07-13 21:57:32 +01:00
break
end
trigger :on_pdirty if e_from_que == :pdirty && pdirty?
trigger :on_mdirty if e_from_que == :mdirty && mdirty?
trigger :on_midi if e_from_que == :midi && get_midi_message
2023-07-13 21:57:32 +01:00
if e_from_que == :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 }
2023-07-14 01:46:25 +01:00
cache[:strip_level] = cache[:strip_buf]
cache[:bus_level] = cache[:bus_buf]
trigger :on_ldirty
2023-07-13 21:57:32 +01:00
end
end
end
end
def init_event_threads
init_worker(@que)
init_producer(@que)
end
def end_event_threads
2023-07-13 21:57:32 +01:00
@running = false
end
module_function :init_event_threads, :end_event_threads
2023-07-13 21:57:32 +01:00
end
end