first_time = time.time()
for j in range(1, 45): #总共876北京城市的
if 1 <= j<= 44:
threads = [gevent.spawn(self.Orange_Financing_Merge, i, "北京") for i in range(1, 20)]
gevent.joinall(threads)
print("\033[0;31m%s\033[0m" % ">>>>>>>>>>>>>>>>>>>>>page %d>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>" % (i))
else:
start_time = time.time()
threads = [gevent.spawn(self.Orange_Financing_Merge, i, "北京") for i in range(1, 16)]
gevent.joinall(threads)
end_time = time.time()
print("总计时间为%d" % (end_time - start_time))
second_time = time.time()
我现在是网页页数是876 页,但是现在我想gevent 异步 并发量是20 ,想40多秒写完,如何去写,我这样写的有问题吗?
gevent.joinall
英文解释:Wait for the
greenlets
to finish.中文解释:等待协程结束
例子: