Python3多線程並獲取返回值

from threading import Thread


class MyThread(Thread):
    def __init__(self, func, *params, **kwargs):
        """
        :param func:    object  待執行的函數對象
        :param params:  tuple   函數的參數
        :param kwargs:  dict    函數的key-value參數
        """
        Thread.__init__(self)
        self.func = func
        self.args = params
        self.kwargs = kwargs
        self.result = None

    # 調用MyThread.start()時該函數會自動執行
    def run(self):
        self.result = self.func(*self.args, **self.kwargs)


class Threads(object):
    """
    並發執行多個線程，並獲取進程的返回值
    """
    def __init__(self):
        self.threads = list()
        self.result = list()  # 進程執行的返回值組成的列表

    def add(self, my_thread):
        """
        將任務添加到待執行線程隊列中
        :param my_thread:   MyThread    線程對象
        :return:
        """
        self.threads.append(my_thread)

    def exec(self):
        """
        多線程同時執行線程隊列中的人物
        :return:
        """
        # 啟動進程序列
        for t in self.threads:
            t.start()

        # 等待進程序列執行完成
        for t in self.threads:
            t.join()

        # 獲取線程返回值
        for t in self.threads:
            self.result.append(t.result)


if __name__ == "__main__":
    from time import sleep

    def test_add(name, a, b, num):
        for i in range(num):
            sleep(1)
            print("{}: {}".format(name, i))
        return a+b

    thread1 = MyThread(test_add, "thread1", 1, 2, 5)
    thread2 = MyThread(test_add, "thread2", a=2, b=3, num=4)
    threads = Threads()
    threads.add(thread1)
    threads.add(thread2)
    threads.exec()
    print(threads.result)