3

我是 Python 新手，所以如果这很明显，我深表歉意。

我正在尝试构建多线程应用程序，但是当我想创建一个线程时，我得到了两个而不是一个。

我的线程.py

from threading import Thread
import time

class MyThreadClass(Thread):

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

    def run(self):
        print "starting " + self.getName() + "\n"
        from main import var1
        while True:
            print self.getName() + " is running\n"
            print "value: " + var1 + "\n"
            time.sleep(1)

主文件

from MyThread import MyThreadClass
var1 = "Test"
MyThreadClass().start()

我得到的输出

 Thread-1 is running
 Thread-2 is running
 Thread-1 is running
 Thread-2 is running
 Thread-1 is running
 Thread-2 is running
 .....

为什么会这样？我注意到如果我替换MyThreadClass().start()为MyThreadClass().run()我得到 2 个线程但只有一个线程继续运行

 Thread-1 is running
 Thread-2 is running
 Thread-2 is running
 Thread-2 is running
 Thread-2 is running
 .....

知道代码有什么问题吗？

4

2 回答 2

9

当您导入main.py时MyThread.py，该行

MyThreadClass().start()

再次执行（因为模块被加载），因此启动了第二个线程。

您可以main.py通过将该行替换为

if __name__ == "__main__":
    MyThreadClass().run()

或者更好的是，只需将var1toMyThreadClass作为参数传递以避免循环依赖。

我的线程.py：

from threading import Thread
import time

class MyThreadClass(Thread):

    def __init__(self, var1):
        Thread.__init__(self)
        self.var1 = var1

    def run(self):
        print "starting " + self.getName() + "\n"
        while True:
            print self.getName() + " is running\n"
            print "value: " + self.var1 + "\n"
            time.sleep(1)

主文件

from MyThread import MyThreadClass

if __name__ == "__main__":
    MyThreadClass("Test").run()
于 2012-08-28T12:10:25.810 回答
4

您启动线程两次，一次是在您运行时main.py（因为它是__main__模块），另一次是在您在MyThreadClass'srun()方法中导入它时。

import语句将运行模块内的所有代码，而不仅仅是您要求的；该from表单便于将特定项目带入您当前的命名空间。

它在两个线程处停止的原因是，即使您main在第二个线程中再次导入，Python 也不会重新执行模块的代码，因为它已经被加载。如果不是这样，您将拥有两个以上的线程；-)

使用另一个答案if __name__ == '__main__':中提到的结构不仅对于这种情况而且对于所有类型的模块都非常有用，因为它允许您执行它们（许多模块将其用于测试代码）并在避免副作用的同时导入它们。

于 2012-08-28T12:13:31.827 回答