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/")
])
本站僅提供存儲服務,所有內容均由用戶發布,如發現有害或侵權內容,請
點擊舉報。