import threadpool,threading
import time,os
def sayhello (a):
print("%shello:%s "%(threading.Thread(),a))
time.sleep(2)
if __name__ == '__main__':
global result
seed = ["a"]
task_pool=threadpool.ThreadPool(2)#创建线程池
#p=Process()创建进程池
#p.apply(func,args.kwargs) 执行进程
#p.close() p.jion()
requests = threadpool.makeRequests(sayhello,seed)#创建任务 makeRequests(func,args,kwargs)
for request in requests:
task_pool.putRequest(request)#把任务put到线程池中
task_pool.wait()#执行等待线程池中的线程执行完毕
------------------------------------------------------------------------------------------
协程
import gevent,os,requests
def func1(url):
data = requests.get(url)
print(data.text)
gevent.joinall([ #开启轮询
gevent.spawn(func1,"http://www.baidu.com"), #注册函数对象并执行函数
gevent.spawn(func1,"https://github.com/")
])
联系客服