Python:同时线程化多个无限循环



在Python中,我试图让一个无限循环同时开始并行运行,一个简单的例子是:

from threading import Thread
def func(argument):
    while True:
        print(argument)
def main():
    Thread(target=func("1")).start()
    Thread(target=func("2")).start()
    Thread(target=func("3")).start()
    Thread(target=func("4")).start()
if __name__ == '__main__':
    main()

现在只有第一个线程运行,所以结果是:

1
1
1
1
....

它应该是:

1
2
3
4
....

发现了几个类似的问题,但提供的解决方案似乎都不适合我,包括在线程上使用join

因此,如果有人知道我的问题的解决方案,将不胜感激。

提前感谢!

第一个线程没有启动。您正在main中调用func并尝试将其返回值设置为 target ,但它永远运行并且永远不会创建第一个线程。你想要:

from threading import Thread
def func(argument):
    while True:
        print(argument)
def main():
    Thread(target=func,args=("1",)).start()
    Thread(target=func,args=("2",)).start()
    Thread(target=func,args=("3",)).start()
    Thread(target=func,args=("4",)).start()
if __name__ == '__main__':
    main()

这会将func作为对象传递。启动线程将使用指定的参数元组调用该对象。

您可以定义自己的线程:

from threading import Thread
class MyThread(Thread):
    def __init__(self,argument, **kwargs):
        super(MyThread, self).__init__(**kwargs)
        self.argument = argument
    def run(self):
        while True:
           print self.argument
if __name__ == '__main__':
    MyThread('1').start()
    MyThread('2').start()
    MyThread('3').start()
    MyThread('4').start()

最新更新