python已协程方式处理任务实现过程

Python  /  管理员 发布于 7年前   163

这篇文章主要介绍了python已协程方式处理任务实现过程,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

#从genent中导入monky模块①from gevent import monkey#把程序变成协程的方式运行②monkey.patch_all()import gevent,requests,time#导入requests和timestart = time.time()#记录程序开始时间 url_list = ['https://www.baidu.com/','https://www.sina.com.cn/','http://www.sohu.com/','https://www.qq.com/','https://www.163.com/','http://www.iqiyi.com/','https://www.tmall.com/','http://www.ifeng.com/']#把8个网站封装成列表 def get_data(url):  r = requests.get(url)  # 用requests.get()函数爬取网站  print(url, time.time()-start,r.status_code) task_list=[]# 创建一个空列表for url in url_list:  # 用gevent里面的spawn函数创建任务 get_data是方法名，url是参数③  task=gevent.spawn(get_data,url)  # 将创建的任务添加到task_list④  task_list.append(task)#执行任务列表中的所有任务⑤gevent.joinall(task_list) end = time.time()#记录程序结束时间print(end-start)#end-start是结束时间减去开始时间，就是最终所花时间。

使用队列，代码如下：

#从genent中导入monky模块①from gevent import monkey#把程序变成协程的方式运行②monkey.patch_all()import gevent,requests,time#从gevent库里导入queue模块from gevent.queue import Queue#导入requests和timestart = time.time()#记录程序开始时间 url_list = ['https://www.baidu.com/','https://www.sina.com.cn/','http://www.sohu.com/','https://www.qq.com/','https://www.163.com/','http://www.iqiyi.com/','https://www.tmall.com/','http://www.ifeng.com/']#把8个网站封装成列表#创建队列对象，并赋值给work。work=Queue()for url in url_list:  # 用put_nowait()函数可以把网址都放进队列里。  work.put_nowait(url)  def get_data():  # 当队列不是空的时候，就执行下面的程序。  while not work.empty():    # 用get_nowait()函数可以把队列里的网址都取出。    url=work.get_nowait()    r = requests.get(url)    # 用requests.get()函数爬取网站 qsize队列长度    print(url, work.qsize(),r.status_code) task_list=[]# 创建一个空列表# 创建了2个爬虫for x in range(2):  # 用gevent里面的spawn函数创建任务 get_data是方法名  task=gevent.spawn(get_data)  # 将创建的任务添加到task_list④  task_list.append(task)#执行任务列表中的所有任务⑤gevent.joinall(task_list) end = time.time()#记录程序结束时间print(end-start)#end-start是结束时间减去开始时间，就是最终所花时间。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。