并发执行方法通常使用多线程或多进程来实现。以下是使用多线程和多进程的两个示例解决方法:
使用多线程的解决方法:
import threading
def my_function(arg):
# 执行需要并发执行的代码
# 创建多个线程并发执行任务
threads = []
for i in range(5):
t = threading.Thread(target=my_function, args=(i,))
threads.append(t)
t.start()
# 等待所有线程执行完毕
for t in threads:
t.join()
使用多进程的解决方法:
import multiprocessing
def my_function(arg):
# 执行需要并发执行的代码
# 创建多个进程并发执行任务
processes = []
for i in range(5):
p = multiprocessing.Process(target=my_function, args=(i,))
processes.append(p)
p.start()
# 等待所有进程执行完毕
for p in processes:
p.join()
以上示例中,my_function
函数是需要并发执行的代码。通过创建多个线程或多个进程,并将my_function
函数作为目标函数传递给线程或进程对象,可以实现并发执行。在多线程解决方法中,使用threading.Thread
类来创建线程,并使用start
方法来启动线程;在多进程解决方法中,使用multiprocessing.Process
类来创建进程,并使用start
方法来启动进程。最后,使用join
方法等待所有线程或进程执行完毕。
上一篇:并发执行的“VACUUMs”
下一篇:并发中的空闲线程有什么术语?