Welcome, guest | Sign In | My Account | Store | Cart
import threading

class myWorker:
	def _threadProc( self):
		"""This is where the work gets done"""
		while 1:
			if self._threadShouldStop():
			If you're waiting on an event in doSomeWorkOrWait that is not expected
			  to return with no activity, then set a largish (~1 second) timeout.
			 If you're using Python 2.2x, you could use generators and yield out
			   every so often.
			obj.doSomeWorkOrWait( TIMEOUT)
			if obj.workIsFinished()
	def watchdog( self):
		If used, this fn should be called "often" - if not, it could be a sign that
		  the calling code has stopped operating as expected.
		  Some time.time() logic could be used in _threadShouldStop 
		   to extend the amount of time available. 
		self._pingCount += 1
	def _threadShouldStop( self):
		""" Return true if there's a reason the thread should stop"""
		manualStop = self.stopThread 
		mainThreadGone = not self.callingThread.isAlive() 
		somethingStalled = self._pingCount == 0
		self._pingCount = 0

		return manualStop or mainThreadGone or somethingStalled
	def startNewThread( self):
		Start a new thread, executing the code in _threadProc.
		We're assuming the main thread, or whichever we want 
		   to depend on being alive, is calling this function.
		self.callingThread = threading.currentThread()
		self.stopThread = 0
		self.thread = threading.Thread( target=self._threadProc)
		self.thread.setDaemon( 0)


  • revision 2 (22 years ago)
  • previous revisions are not available