10.3 threading:进程中管理并发操作
threading模块提供了管理多个线程执行的API,允许程序在同一个进程空间并发地运行多个操作。
10.3.1 Thread对象
要使用Thread,最简单的方法就是用一个目标函数实例化一个Thread对象,并调用start()让它开始工作。
import threading
def worker():
"""thread worker function"""
print('Worker\n')
threads = []
for i in range(5):
t = threading.Thread(target=worker)
threads.append(t)
t.start()
输出有5行,每一行都是“Worker”:
如果能够创建一个线程,并向它传递参数告诉它要完成什么工作,那么这会很有用。任何类型的对象都可以作为参数传递到线程。下面的例子传递了一个数,线程将打印出这个数。
import threading
def worker(num):
"""thread worker function"""
print('Worker: %s\n' % num)
threads = []
for i in range(5):
t = threading.Thread(target=worker,args=(i,))
threads.append(t)
t.start()
现在这个整数参数会包含在各线程打印的消息中。
运行结果: