-
-
Save inap-bannai/5fbc522a4333d4c3d0c182a639df36dc 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