-
-
Save fogdingding/40f5093a505c42f0db0fc1758e1e38c8 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() |
Author
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
this is so great