Class: Worker::Base

Inherits:

Object

• Object
• Worker::Base

Defined in:

lib/buzzcore/extra/thread_utils.rb

Constant Summary

TempDirectory =

Dir.tmpdir

Class Method Summary

• .pid_filename ⇒ Object

Instance Method Summary

• #logger ⇒ Object
• #main_proc ⇒ Object
• #running ⇒ Object
• #starting ⇒ Object
• #stop ⇒ Object
• #stopping ⇒ Object
• #wait_for_started(aTimeout) ⇒ Object
• #wait_for_stopped(aTimeout) ⇒ Object

Class Method Details

.pid_filename ⇒ Object

# File 'lib/buzzcore/extra/thread_utils.rb', line 409

def self.pid_filename
	File.join(TempDirectory, "#{name}.pid")
end

Instance Method Details

#logger ⇒ Object

# File 'lib/buzzcore/extra/thread_utils.rb', line 413

def logger
	if not @logger
		@logger = Logger.new(STDERR)
		@logger.level = Logger::DEBUG
	end
	@logger
end

#main_proc ⇒ Object

# File 'lib/buzzcore/extra/thread_utils.rb', line 421

def main_proc
	begin
		@is_stopped = false
		@is_started = false
		self.starting()
		@is_started = true
		@is_stopping = false
		while !@is_stopping do
			running();
			logger.debug { "ServiceThread running loop: @is_stopping="+@is_stopping.to_s }
		end
	rescue SystemExit => e  # smother and do nothing
	rescue Exception => e
		logger.warn { "Thread #{@name} #{e.inspect} exception in Starting() or Running()" }
		logger.warn { e.backtrace       }
	ensure
		@is_stopping = true
	end
	
	begin
		stopping()
	rescue Exception => e
		logger.warn { "Thread #{@name} #{e.inspect} exception in stopping()" }
		logger.warn { e.backtrace       }
	end
	logger.info { "Thread #{@name} dropped out"  }
	@is_stopped = true
end

#running ⇒ Object

# File 'lib/buzzcore/extra/thread_utils.rb', line 473

def running
end

#starting ⇒ Object

# File 'lib/buzzcore/extra/thread_utils.rb', line 470

def starting
end

#stop ⇒ Object

# File 'lib/buzzcore/extra/thread_utils.rb', line 466

def stop
	@is_stopping = true
end

#stopping ⇒ Object

# File 'lib/buzzcore/extra/thread_utils.rb', line 476

def stopping
end

#wait_for_started(aTimeout) ⇒ Object

Raises:

• (Timeout::Error)

# File 'lib/buzzcore/extra/thread_utils.rb', line 450

def wait_for_started(aTimeout)
	before = Time.now
	while !@is_started and (Time.now-before) < aTimeout
		sleep(aTimeout / 10)
	end
	raise Timeout::Error.new("failed to start within timeout (#{aTimeout.to_s})") if !@is_started
end

#wait_for_stopped(aTimeout) ⇒ Object

Raises:

• (Timeout::Error)

# File 'lib/buzzcore/extra/thread_utils.rb', line 458

def wait_for_stopped(aTimeout)
	before = Time.now
	while !@is_stopped and (Time.now-before) < aTimeout
		sleep(aTimeout / 10)
	end
	raise Timeout::Error.new("failed to stop within timeout (#{aTimeout.to_s})") if !@is_stopped
end