如何在Python中传递和运行回调方法

Question

我有一个Manager(主线程),它创建其他线程来处理各种操作.我希望我的经理在创建的线程结束时(当run()方法执行完成时)得到通知.

我知道我可以通过Thread.isActive()方法检查所有线程的状态,但轮询很糟糕,所以我想要通知.

我正在考虑给Threads一个回调方法,并在run()方法结束时调用这个函数:

class Manager():
    ...
    MyThread(self.on_thread_finished).start() # How do I pass the callback

    def on_thread_finished(self, data):
        pass
    ...

class MyThread(Thread):
    ...
    def run(self):
        ....
        self.callback(data) # How do I call the callback?
    ...

谢谢!

Answer 1

线程无法调用管理器,除非它具有对管理器的引用.最简单的方法是让管理员在实例化时将它提供给线程.

class Manager(object):
    def new_thread(self):
        return MyThread(parent=self)
    def on_thread_finished(self, thread, data):
        print thread, data

class MyThread(Thread):

    def __init__(self, parent=None):
        self.parent = parent
        super(MyThread, self).__init__()

    def run(self):
        # ...
        self.parent and self.parent.on_thread_finished(self, 42)

mgr    = Manager()
thread = mgr.new_thread()
thread.start()

如果您希望能够将任意函数或方法指定为回调,而不是存储对管理器对象的引用,则由于方法包装器等原因,这会变得有点问题.很难设计回调,因此它获得了对管理器和线程的引用,这就是你想要的.我曾经研究过一段时间,并没有想出任何我认为有用或优雅的东西.

Answer 2

这样做有什么不对吗？

from threading import Thread

class Manager():
    def Test(self):
        MyThread(self.on_thread_finished).start()

    def on_thread_finished(self, data):
        print "on_thread_finished:", data

class MyThread(Thread):
    def __init__(self, callback):
        Thread.__init__(self)
        self.callback = callback

    def run(self):
        data = "hello"
        self.callback(data)

m = Manager()
m.Test() # prints "on_thread_finished: hello"