Skip to content

Instantly share code, notes, and snippets.

@inap-bannai
Forked from amirasaran/BaseThreading
Created March 25, 2021 03:16
Show Gist options
  • Save inap-bannai/5fbc522a4333d4c3d0c182a639df36dc to your computer and use it in GitHub Desktop.
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)
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