Class: WorkerThread

Inherits:
Object
  • Object
show all
Defined in:
lib/worker_thread.rb

Overview

Helper for running threads in the background, with a timeout and error logging.

Example:

WorkerThread.new.start :timeout => 5.minutes do 
    # long running task here...
    sleep 10.0
end

Instance Method Summary collapse

Instance Method Details

#start(options = nil) ⇒ Object 



13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
 
# File 'lib/worker_thread.rb', line 13

def start(options = nil)
	raise 'background_task needs a block' unless block_given?

	options ||= {}

	worker = Thread.new do
		begin
			yield
		rescue => e
			$stderr.puts "#{Time.now}\t#{e.class.to_s}\t#{e.message}\n"
			raise e
		end
	end

	# if the user set a timeout then we need a thread to monitor
	# the worker to make sure it doesn't run too long
	if !options[:timeout].nil?
		Thread.new do
			sleep options[:timeout].to_f
			
			if worker.status != false
				#$stderr.puts "#{Time.now}\tbackground_task thread timeout\n"
				worker.kill
			end
		end
	end

	worker
end