使用线程实现多线程进程的简单方法

相同的代码片段

import threading

#function which takes some time to process 
def say(i):
    time.sleep(1)
    print(i)

threads = []
for i in range(10):
    
    thread = threading.Thread(target=say, args=(i,))

    thread.start()
    threads.append(thread)

#wait for all threads to complete before main program exits 
for thread in threads:
    thread.join()

你可以在Thread构造函数中使用target参数直接传入一个被调用的函数，而不是run。

你重写run()方法了吗?如果你重写了__init__，你是否确保调用了基本线程threading.Thread.__init__()?

在启动两个线程之后，主线程是否继续在子线程上无限地/阻塞/连接工作，以便在子线程完成任务之前主线程的执行不会结束?

最后，是否有任何未处理的异常?

使用线程实现多线程进程的简单方法

相同的代码片段

import threading

#function which takes some time to process 
def say(i):
    time.sleep(1)
    print(i)

threads = []
for i in range(10):
    
    thread = threading.Thread(target=say, args=(i,))

    thread.start()
    threads.append(thread)

#wait for all threads to complete before main program exits 
for thread in threads:
    thread.join()

你不需要使用Thread的子类来实现这个工作——看看我下面发布的简单示例，看看如何做到这一点:

from threading import Thread
from time import sleep

def threaded_function(arg):
    for i in range(arg):
        print("running")
        sleep(1)


if __name__ == "__main__":
    thread = Thread(target = threaded_function, args = (10, ))
    thread.start()
    thread.join()
    print("thread finished...exiting")

在这里，我将展示如何使用threading模块创建一个线程，该线程将调用一个普通函数作为其目标。你可以看到我如何在线程构造函数中传递我需要的任何参数。

我尝试添加另一个join()，它似乎有效。这是代码

from threading import Thread
from time import sleep

def function01(arg,name):
    for i in range(arg):
        print(name,'i---->',i,'\n')
        print (name,"arg---->",arg,'\n')
        sleep(1)

def test01():
    thread1 = Thread(target = function01, args = (10,'thread1', ))
    thread1.start()
    thread2 = Thread(target = function01, args = (10,'thread2', ))
    thread2.start()
    thread1.join()
    thread2.join()
    print ("thread finished...exiting")

test01()