Example

from sine.threads import *

def func(stop_event):
	while 1:
		if stop_event.is_set():
			break
		# do your work

thread = StoppableThread(target=func)
thread.start()
# ...
thread.stop(-1) # stop and join forever
# thread.stopped() == True


thread = ReStartableThread(target=func, event_name='stop_event') # can specify the parameter's name
thread.start()
# ...
thread.stop(1) # stop and join for 1 second
# ...
thread.start()
# ...
thread.stop()
thread.join()
# ...

Changelog

v0.1.7, 2019-2-9

• change to run with python3

v0.1.6, 2018-10-7

• stop() become stop(timeout=0) to join the thread for convenience and return whether it is alive.
• when the event_name is not specified, it is not strict to receive the stop event any more, and it will be added to 'args' so it can be receive by *args' or other argument
• add: thread lock

v0.1.5, 2018-9-11

• fix logic about join(), when directly join() without start() but stop()

v0.1.4, 2018-6-7

• ReStartableThread support join the old thread instance
• fix: ReStartableThread.start always creates new instance
• improve comment and change to English
• change directory structure and update setup.py
• add tests.py