多子类中的 Python 线程答案

【问题标题】：Python threading in multi subclasses多子类中的 Python 线程
【发布时间】：2016-05-02 05:11:23
【问题描述】：

我有一系列以串行和并行方式继承的类，我需要尽可能对所有类使用 Python 线程。下面是一个例子。问题是 Build 类没有执行它的 run 函数，这是 Thread 类中的一个方法。不过，线程在 MyThread 类中工作正常。知道如何使 Build 类作为线程开始吗？

from threading import Thread
from random import randint
import time

class Build(Thread):
    def __init__(self):
        Thread.__init__(self)

    def run(self):    
        # This run function currently not being executed 
        for i in range(20):
            print('Second series %i in thread' % (i))
            time.sleep(1)

class MyThread(Build, Thread):

    def __init__(self, val):
        ''' Constructor. '''
        Thread.__init__(self)
        Build.__init__(self)

        self.val = val


    def run(self):
        for i in range(1, self.val):
            print('Value %d in thread %s' % (i, self.getName()))

            # Sleep for random time between 1 ~ 3 second
            secondsToSleep = randint(1, 5)
            print('%s sleeping fo %d seconds...' % (self.getName(), secondsToSleep))
            time.sleep(secondsToSleep)


# Run following code when the program starts
if __name__ == '__main__':
    # Declare objects of MyThread class
    myThreadOb1 = MyThread(4)
    myThreadOb1.setName('Thread 1')

    myThreadOb2 = MyThread(4)
    myThreadOb2.setName('Thread 2')

    # Start running the threads!
    myThreadOb1.start()
    myThreadOb2.start()

    # Wait for the threads to finish...
    myThreadOb1.join()
    myThreadOb2.join()

    print('Main Terminating...')`

【问题讨论】：

似乎有效。我尝试了您的代码并将MyThread() 之一替换为Build()，它正确调用了run()。

标签： python multithreading class

【解决方案1】：

仅供参考：不是继承 threading.Thread 实现您想要的更好的方法是使您的类实例 Callable 并将它们传递给 target 关键字 arg Thread 类的构造函数。这样做的好处是您可以向每个 Thread 实例传递额外的参数。

使用您的示例代码。

class MyThread(Build):

    def __init__(self):
        ''' Constructor. '''
        Build.__init__(self)

        self.val = val

    # this allows your class to be a callable.
    def __call__(self, val):
        for i in range(1, val):
            print('Value %d in thread %s' % (i, self.getName()))

            # Sleep for random time between 1 ~ 3 second
            secondsToSleep = randint(1, 5)
            print('%s sleeping fo %d seconds...' % (self.getName(), secondsToSleep))
            time.sleep(secondsToSleep)

# Run following code when the program starts
if __name__ == '__main__':
    # Declare objects of MyThread class
    myThreadObj1 = MyThread()
    myThread1 = Thread(target=myThreadOb1, args=(4))
    myThread1.start()

【讨论】：