任务:读取文件每一行,并执行相应的操作(以打印行内容为例)。
for循环方式:
f = open('test.txt', 'r')
for line in f.readlines():
print(line)
f.close()
线程池方式:
from multiprocessing.pool import ThreadPool
def my_print(item):
print(item)
pool_size = 10
f = open('test.txt', 'r')
items = f.readlines()
pool = ThreadPool(pool_size) # 创建一个线程池
pool.map(my_print, items) # 往线程池中填线程
pool.close() # 关闭线程池,不再接受线程
pool.join() # 等待线程池中线程全部执行完