前言
这几年一直在it行业里摸爬滚打,一路走来,不少总结了一些python行业里的高频面试,看到大部分初入行的新鲜血液,还在为各样的面试题答案或收录有各种困难问题
于是乎,我自己开发了一款面试宝典,希望能帮到大家,也希望有更多的Python新人真正加入从事到这个行业里,让python火不只是停留在广告上。
微信小程序搜索:Python面试宝典
或可关注原创个人博客:https://lienze.tech
也可关注微信公众号,不定时发送各类有趣猎奇的技术文章:Python编程学习
线程池
池的概念在于,预先创建好一定数量的线程,可以不需要多次重复创建,避免频繁的生产和释放线程资源导致的系统资源浪费
from multiprocessing.pool import ThreadPool
tp = ThreadPool(3) # 创建一定个数的进程池
p.apply(func, args) # 阻塞方式,调用函数及传入参数,下个线程阻塞直到上个线程结束
p.apply_async(func, args) # 非阻塞方式,调用函数及传入参数,并发完成任务
p.close() # 关闭线程池不在接收新的任务进入
p.join() # 父进程等待全部子线程结束,必须在close函数之后
p.terminat() # 直接关闭线程池并终止所有线程任务
- 代码示例
from multiprocessing.pool import ThreadPool
from threading import currentThread,Lock
import time
def work(obj,l=None):
with l:
obj[0] += 1
print('当前线程是:',currentThread().name,':',obj)
time.sleep(0.5)
return obj
def main():
l = Lock()
mylist = [1]
p = ThreadPool(10)
#print(help(ThreadPool))
res = []
for var in range(10):
# res.append(p.apply(func=work,args=(mylist,l)))
res.append(p.apply_async(func=work,args=(mylist,l)))
p.close() #关闭进程池
p.join()
#print(res) #apply
for var in res: #apply_async
print(var.get(),end=' ')
print('\nover')
if __name__ == '__main__':
main()
代码中包含了对于线程池执行结果的返回,与进程池是相似的。