Teek::BackgroundThread::BackgroundWork Class
Inherits: Object
Instance Methods ↑
close
View source ▼
def close
@done = true
@worker_thread&.kill
self
end
initialize(app, data, worker: nil, &block)
Returns BackgroundWork — a new instance of BackgroundWork
View source ▼
def initialize(app, data, worker: nil, &block)
# Thread mode supports both block and worker class for API consistency
@app = app
@data = data
@work_block = block || (worker && proc { |t, d| worker.new.call(t, d) })
@callbacks = { progress: nil, done: nil, message: nil }
@started = false
@done = false
@paused = false
# Communication channels
@output_queue = Thread::Queue.new # Worker -> Main
@message_queue = Thread::Queue.new # Main -> Worker
@worker_thread = nil
endon_done(&block)
View source ▼
def on_done(&block)
@callbacks[:done] = block
maybe_start
self
endon_message(&block)
Called when worker sends a non-result message back
View source ▼
def on_message(&block)
@callbacks[:message] = block
self
endon_progress(&block)
View source ▼
def on_progress(&block)
@callbacks[:progress] = block
maybe_start
self
endresume
View source ▼
def resume
@paused = false
send_message(:resume)
# Restart polling (was stopped when paused)
@app.after(0, &@poll_proc) if @poll_proc && !@done
self
endsend_message(msg)
Send a message to the worker (pause, resume, stop, or custom)
View source ▼
def send_message(msg)
@message_queue << msg
self
endstart
View source ▼
def start
return self if @started
@started = true
@worker_thread = Thread.new do
Thread.current[:tk_in_background_work] = true
task = TaskContext.new(@output_queue, @message_queue)
begin
@work_block.call(task, @data)
@output_queue << [:done]
rescue StopIteration
@output_queue << [:done]
rescue => e
@output_queue << [:error, "#{e.class}: #{e.message}\n#{e.backtrace.first(3).join("\n")}"]
@output_queue << [:done]
end
end
start_polling
self
endstop
View source ▼
def stop
send_message(:stop)
self
end