一个简单的python多协程实例，,importxlrd

一个简单的python多协程实例，,importxlrd

importxlrd,threading,requests,threading,json,time,mathimportnumpyasnpimportgevent

fromqueueimportQueue

products=Queue()result=Queue()defexcel():wb=xlrd.open_workbook(r‘E:/python/xt_user.xlsx‘)sheet=wb.sheet_by_name(‘xt_user‘)forainrange(sheet.nrows):cells=sheet.row_values(a)products.put(cells)defconsumer():whilenotproducts.empty():obj=products.get()res=thread_test(obj)print(res)result.put(res)defthread_test(object):url=‘‘r=requests.post(url,data=json.dumps({}),headers={‘Content-Type‘:‘application/json‘})#print(r.json())returnr.json()excel()g1=gevent.spawn(consumer)

g2=gevent.spawn(consumer)g3=gevent.spawn(consumer)g1.join()g2.join()g3.join()g4=gevent.spawn(consumer)g5=gevent.spawn(consumer)g6=gevent.spawn(consumer)g4.join()g5.join()g6.join()time.sleep(10)success=0fail=0whilenotresult.empty():obj=result.get()ifobj[‘status‘]==200:print(obj)success+=1else:print(‘请求失败‘)fail+=1print(‘成功个数:‘,success)print(‘失败个数:‘,fail)

一个简单的python多协程实例