python中的多线程其实并非真正的多线程,若是想要充分地使用多核CPU的资源,在python中大部分状况须要使用多进程。Python提供了很是好用的多进程包multiprocessing,只须要定义一个函数,Python会完成其余全部事情。借助这个包,能够轻松完成从单进程到并发执行的转换
其实多进程没有咱们想象的那么难,用几个小例子给你们分享一下!html
1 import turtle 2 3 def cir(n,m): 4 turtle.penup() 5 turtle.goto(n) 6 turtle.pendown() 7 turtle.circle(m) 8 time.sleep(1) 9 def runn(lis1,lis2): 10 for n, m in zip(lis1,lis2): 11 cir(n,m) 12 if __name__ == '__main__': 13 nn = [(0,-200),(0,-150),(0,-100),(0,-50)] 14 mm = [200,150,100,50] 15 runn(nn,mm)
这段代码,实现了画4个同心圆的效果,若是用多进程的话,咱们稍微该写一下,将runn()函数替换下面的代码python
能够看到,这里直接生成4个画板同时画同心圆。若是还要在加进程的话,能够用pool进程池,注意pool有2个方法,建议用非阻塞的p.apply_async不要用阻塞的p.apply方法,p.apply_async会由系统自行判断并运行,好比指定4个进程运行5个任务,那么会在某一个进程运行完毕的同时自动开始第5个任务,而阻塞的p.apply方法会一次只运行一个进程。网络
1 p = Pool(9) 2 for i in range(9): 3 p.apply_async(runn,(nn,mm))#非阻塞 4 #p.apply(runn,(nn,mm))#阻塞 5 p.close() 6 p.join()
Pool()里面不带参数会自动适应电脑自己内核数量,这里我设置9个进程同时进行!来看看效果多线程
def cir(m): turtle.penup() turtle.goto(m[0]) turtle.pendown() turtle.circle(m[1]) time.sleep(14) if __name__ == '__main__': nn = [(0, -200), (0, -150), (0, -100), (0, -50)] mm = [200, 150, 100, 50] mn = [(x,y) for x,y in zip(nn,mm)] p = Pool(3) p.map(cir,mn)
此次不画4个同心圆了,咱们让它4个进程各画一个圆,来看看效果并发
import requests from lxml import etree import time from multiprocessing import Process,Pool def main(url): time.sleep(1) html = requests.get(url) html.encoding = 'gb2312' data = etree.HTML(html.text) title = data.xpath('//a[@class="ulink"]/text()') summary = data.xpath('//td[@colspan="2"]/text()') urls = data.xpath('//a[@class="ulink"]/@href') for t,s,u in zip(title,summary,urls): print(t) print('【url:】http://www.dytt8.net'+u) print('【简介】>>>>>>>'+s) if __name__ == '__main__': start = time.time() url = 'http://www.dytt8.net/html/gndy/dyzz/' pg_url = [url+'list_23_{}.html'.format(str(x)) for x in range(1,10)] for pg_u in pg_url: main(pg_u) end = time.time() print("共计用时%.4f秒"%(end-start))
pg_url = [url+'list_23_{}.html'.format(str(x)) for x in range(1,10)] # for pg_u in pg_url: # main(pg_u) p=Pool() p.map(main,pg_url) end = time.time() print("共计用时%.4f秒"%(end-start))