您好,登錄后才能下訂單哦!
協(xié)程,又稱微線程,即為輕量級的線程。
python中實(shí)現(xiàn)協(xié)程是基于Gevent模塊,Gevent模塊內(nèi)部封裝了greenlet模塊;greenlet模塊實(shí)現(xiàn)了在單線程中切換狀態(tài),Gevent模塊在此之上還實(shí)現(xiàn)了遇到I/O操作自動切換,使程序運(yùn)行更快;但是Gevent只在遇到自己認(rèn)識的I/O操作時切換,所以需要使用Gevent包的一個模塊:猴子補(bǔ)丁,使用了這個補(bǔ)丁,Gevent會直接修改在它之后導(dǎo)入的模塊中的I/O操作,使其可以讓Gevent識別,從而開啟協(xié)程。
Greenlet與Gevent模塊都是python的第三方模塊,需安裝使用。
g = greenlet(run=None, parent=None):實(shí)例化一個greenlet對象
g.parent:每一個協(xié)程都有一個父協(xié)程,當(dāng)前協(xié)程結(jié)束后會回到父協(xié)程中執(zhí)行,該屬性默認(rèn)是創(chuàng)建該協(xié)程的協(xié)程
g.run: 該屬性是協(xié)程實(shí)際運(yùn)行的代碼. run方法結(jié)束了,那么該協(xié)程也就結(jié)束了
g.switch(*args, **kwargs): 切換到g協(xié)程
g.throw(): 切換到g協(xié)程,接著拋出一個異常
from greenlet import greenlet
def work():
print("1")
g2.switch() # 切換到g2協(xié)程
print("3")
g2.switch()
def work2():
print("2")
g1.switch()
print("4")
g1 = greenlet(work) # 創(chuàng)建一個greenlet實(shí)例
g2 = greenlet(work2)
g1.switch() # 切換到g1協(xié)程
1
2
3
4
from gevent import monkey
monkey.patch_all() # monkey補(bǔ)丁會將在它之后導(dǎo)入的模塊的IO操作打包,使gevent認(rèn)識他們
import gevent
def work1():
print("1")
gevent.sleep(1)
print("3")
def work2():
print("2")
gevent.sleep(1)
print("4")
g1 = gevent.spawn(work1)
g2 = gevent.spawn(work2)
# g1.join()
# g2.join()
gevent.joinall([g1,g2])
from gevent import monkey;monkey.patch_all()
import gevent
import requests
def get_url(url):
res = requests.get(url)
print(url,res.status_code,len(res.text))
url_l = [
'http://www.baidu.com',
'http://www.google.com',
'https://zh.wikipedia.org/wiki/Wikipedia:%E9%A6%96%E9%A1%B5',
'https://www.youtube.com/?app=desktop',
'https://www.facebook.com/',
'http://www.python.org',
'http://www.cnblogs.com'
]
g_l = []
for i in url_l:
g_l.append(gevent.spawn(get_url,i))
gevent.joinall(g_l)
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報,并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。