-
-
Save Omar-AE/018065049891a98257c61a3f68e6c7ce 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