国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 編程 > Python > 正文

Python的gevent框架的入門教程

2020-02-23 00:59:03
字體:
來源:轉載
供稿:網友

Python通過yield提供了對協程的基本支持,但是不完全。而第三方的gevent為Python提供了比較完善的協程支持。

gevent是第三方庫,通過greenlet實現協程,其基本思想是:

當一個greenlet遇到IO操作時,比如訪問網絡,就自動切換到其他的greenlet,等到IO操作完成,再在適當的時候切換回來繼續執行。由于IO操作非常耗時,經常使程序處于等待狀態,有了gevent為我們自動切換協程,就保證總有greenlet在運行,而不是等待IO。

由于切換是在IO操作時自動完成,所以gevent需要修改Python自帶的一些標準庫,這一過程在啟動時通過monkey patch完成:

from gevent import monkey; monkey.patch_socket()import geventdef f(n):  for i in range(n):    print gevent.getcurrent(), ig1 = gevent.spawn(f, 5)g2 = gevent.spawn(f, 5)g3 = gevent.spawn(f, 5)g1.join()g2.join()g3.join()

運行結果:

<Greenlet at 0x10e49f550: f(5)> 0<Greenlet at 0x10e49f550: f(5)> 1<Greenlet at 0x10e49f550: f(5)> 2<Greenlet at 0x10e49f550: f(5)> 3<Greenlet at 0x10e49f550: f(5)> 4<Greenlet at 0x10e49f910: f(5)> 0<Greenlet at 0x10e49f910: f(5)> 1<Greenlet at 0x10e49f910: f(5)> 2<Greenlet at 0x10e49f910: f(5)> 3<Greenlet at 0x10e49f910: f(5)> 4<Greenlet at 0x10e49f4b0: f(5)> 0<Greenlet at 0x10e49f4b0: f(5)> 1<Greenlet at 0x10e49f4b0: f(5)> 2<Greenlet at 0x10e49f4b0: f(5)> 3<Greenlet at 0x10e49f4b0: f(5)> 4

可以看到,3個greenlet是依次運行而不是交替運行。

要讓greenlet交替運行,可以通過gevent.sleep()交出控制權:

def f(n):  for i in range(n):    print gevent.getcurrent(), i    gevent.sleep(0)

執行結果:

<Greenlet at 0x10cd58550: f(5)> 0<Greenlet at 0x10cd58910: f(5)> 0<Greenlet at 0x10cd584b0: f(5)> 0<Greenlet at 0x10cd58550: f(5)> 1<Greenlet at 0x10cd584b0: f(5)> 1<Greenlet at 0x10cd58910: f(5)> 1<Greenlet at 0x10cd58550: f(5)> 2<Greenlet at 0x10cd58910: f(5)> 2<Greenlet at 0x10cd584b0: f(5)> 2<Greenlet at 0x10cd58550: f(5)> 3<Greenlet at 0x10cd584b0: f(5)> 3<Greenlet at 0x10cd58910: f(5)> 3<Greenlet at 0x10cd58550: f(5)> 4<Greenlet at 0x10cd58910: f(5)> 4<Greenlet at 0x10cd584b0: f(5)> 4

3個greenlet交替運行,

把循環次數改為500000,讓它們的運行時間長一點,然后在操作系統的進程管理器中看,線程數只有1個。

當然,實際代碼里,我們不會用gevent.sleep()去切換協程,而是在執行到IO操作時,gevent自動切換,代碼如下:

from gevent import monkey; monkey.patch_all()import geventimport urllib2def f(url):  print('GET: %s' % url)  resp = urllib2.urlopen(url)  data = resp.read()  print('%d bytes received from %s.' % (len(data), url))gevent.joinall([    gevent.spawn(f, 'https://www.python.org/'),    gevent.spawn(f, 'https://www.yahoo.com/'),    gevent.spawn(f, 'https://github.com/'),])            
發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 青州市| 建湖县| 政和县| 太仆寺旗| 托克逊县| 麦盖提县| 蛟河市| 资阳市| 清流县| 宜州市| 龙胜| 军事| 错那县| 永平县| 阳曲县| 大埔区| 耒阳市| 绩溪县| 东丽区| 边坝县| 铜鼓县| 广昌县| 永德县| 卓尼县| 迭部县| 贵港市| 醴陵市| 繁昌县| 循化| 饶河县| 瓦房店市| 金坛市| 渑池县| 姚安县| 瑞丽市| 襄城县| 崇信县| 高雄县| 博白县| 延吉市| 江口县|