-
-
Save coci/1c51a24c14a07fcbc46e8ecde31daf13 to your computer and use it in GitHub Desktop.
Python threading with callback function (callback function run after thread is finished)
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import time | |
import threading | |
class BaseThread(threading.Thread): | |
def __init__(self, callback=None, callback_args=None, *args, **kwargs): | |
target = kwargs.pop('target') | |
super(BaseThread, self).__init__(target=self.target_with_callback, *args, **kwargs) | |
self.callback = callback | |
self.method = target | |
self.callback_args = callback_args | |
def target_with_callback(self): | |
self.method() | |
if self.callback is not None: | |
self.callback(*self.callback_args) | |
def my_thread_job(): | |
# do any things here | |
print "thread start successfully and sleep for 5 seconds" | |
time.sleep(5) | |
print "thread ended successfully!" | |
def cb(param1, param2): | |
# this is run after your thread end | |
print "callback function called" | |
print "{} {}".format(param1, param2) | |
# example using BaseThread with callback | |
thread = BaseThread( | |
name='test', | |
target=my_thread_job, | |
callback=cb, | |
callback_args=("hello", "world") | |
) | |
thread.start() |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment