V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
推荐学习书目
Learn Python the Hard Way
Python Sites
PyPI - Python Package Index
http://diveintopython.org/toc/index.html
Pocoo
值得关注的项目
PyPy
Celery
Jinja2
Read the Docs
gevent
pyenv
virtualenv
Stackless Python
Beautiful Soup
结巴中文分词
Green Unicorn
Sentry
Shovel
Pyflakes
pytest
Python 编程
pep8 Checker
Styles
PEP 8
Google Python Style Guide
Code Style from The Hitchhiker's Guide
xueqt
V2EX  ›  Python

greenlet 的 join 到底如何理解,希望赐教!!

  •  
  •   xueqt · 2016-08-11 11:09:09 +08:00 · 2582 次点击
    这是一个创建于 3019 天前的主题,其中的信息可能已经有所发展或是发生改变。

    这两天用到 gevent 写个服务器,对于 join 的印象还是停留在比较模糊的阶段,好像就这么用着用着也没事 贴一下 greenlet 中 join 的相关源码,感觉 gevent 中比较绕的就是这个 switch ,所有类的方法都叫一个 switch 这里是讲当前 greenlet 的回调用 rawlink 注册到一个双端链表,然后再切换到 hub ,我看说 join 是当所有 greenlet 都运行完毕之后再依次回调,这个回调具体是咋操作的,又是怎么回到 main 的呢 还请好心朋友赐教一下,一言千金

    def join(self, timeout=None):
        """Wait until the greenlet finishes or *timeout* expires.
        Return ``None`` regardless.
        """
        if self.ready():
            return
    
        switch = getcurrent().switch
        self.rawlink(switch)
        try:
            t = Timeout._start_new_or_dummy(timeout)
            try:
                result = self.parent.switch()
                if result is not self:
                    raise InvalidSwitchError('Invalid switch into Greenlet.join(): %r' % (result, ))
            finally:
                t.cancel()
        except Timeout as ex:
            self.unlink(switch)
            if ex is not t:
                raise
        except:
            self.unlink(switch)
            raise
    
    6 条回复    2016-08-11 16:54:03 +08:00
    xueqt
        1
    xueqt  
    OP
       2016-08-11 11:10:20 +08:00
    来个人 O(∩_∩)O~
    xueqt
        2
    xueqt  
    OP
       2016-08-11 11:34:43 +08:00
    不完全整明白吃不下饭啊,快来人帮个忙
    zenliver
        3
    zenliver  
       2016-08-11 11:54:35 +08:00
    通过 greenlet 切换的
    SlipStupig
        4
    SlipStupig  
       2016-08-11 12:04:25 +08:00
    @xueqt 说的很清楚了啊,直到任务完成或超时, grenlet 全部注册在 gevent Hub 里面,然后根据 greenlet 的定时去就主动切换,如果超时了就退出,剩下就是等任务完成了,然后从 Hub 取消注册,有点像回调注册!
    xueqt
        5
    xueqt  
    OP
       2016-08-11 13:58:07 +08:00
    @SlipStupig 是从 hub 取消注册后再回调 notify_link 吗
    xueqt
        6
    xueqt  
    OP
       2016-08-11 16:54:03 +08:00
    明白了,虽然 join 没有向 hub 注册回调,但是当 Greenlet 结束最后会调用_report_result 方法,这时候_report_result 把将_notify_links 注册到 loop 的回调中,最后由_notify_links 回调之前注册在自己回调链上的 switch
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   实用小工具   ·   2656 人在线   最高记录 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 24ms · UTC 11:23 · PVG 19:23 · LAX 03:23 · JFK 06:23
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.