gunicorn geventworker 解析

　　在前面的文章曾介紹過gunicorn的syncworker，本文介紹其中一種asyncworker：GeventWorker。類圖如下：

 

　　可見GeventWorker重載了init_process(這個方法是Worker唯一暴露給外界的接口），源碼如下：

        def init_process(self):
            # monkey patch here
            self.patch()

            # reinit the hub
            from gevent import hub
            hub.reinit()

            # then initialize the process
            super(GeventWorker, self).init_process()

　　首先是monkey-patch，這個是使用gevent所必須的的；然后調用hub.reinit，這個在fork子進程之后必須調用；最后調用基類的init_process。關於gevent hub的reinit，在gevent源碼的doc里寫的很清楚：

　　This should be called *immediately* after :func:`os.fork` in the child process. This is done automatically by :func:`gevent.os.fork` or if the :mod:`os` module has beenmonkey-patched. If this function is not called in a forked process, symptoms may include hanging of functions like :func:`socket.getaddrinfo`, and the hub's threadpool is unlikelyto work.

　　前面也提到了init_process會帶用到run方法，進入循環，我們看看GeventWorker.run:

　　

    def run(self):
        servers = []
        ssl_args = {}

        if self.cfg.is_ssl:
            ssl_args = dict(server_side=True, **self.cfg.ssl_options)

        for s in self.sockets:
            s.setblocking(1)
            pool = Pool(self.worker_connections) # Pool是Gevent.Pool
            if self.server_class is not None:
                environ = base_environ(self.cfg)
                environ.update({
                    "wsgi.multithread": True,
                    "SERVER_SOFTWARE": VERSION,
                })
                server = self.server_class(
                    s, application=self.wsgi, spawn=pool, log=self.log,
                    handler_class=self.wsgi_handler, environ=environ,
                    **ssl_args)
            else:
                hfun = partial(self.handle, s) # self.handle為請求到達時候的處理函數
                server = StreamServer(s, handle=hfun, spawn=pool, **ssl_args)

            server.start()
            servers.append(server)

        while self.alive: # 每隔1s告知Arbiter自己還活着
            self.notify() 
            gevent.sleep(1.0)   # 切換回hub

 　　邏輯也比較簡單，首先是建立TCP Server（gevent.StreamServer），並且傳入tcp連接到達時得處理函數self.handle, 然后TCP Server開始工作（server.start）， 關於gevent具體怎么在多個協程之間調度，可以參加之前的文章。最后的while循環(28行)用於向Arbiter發心跳，並通過gevent.sleep立即切回hub。再來看看上述代碼的第10行：pool = Pool(self.worker_connections) ，這個worker_connections屬性來自gunicorn的配置，默認為1000，表明單個worker可以維持的連接數目。然后gevent.Pool的作用可以再gevent tutorial查看，簡單來說，就是規定了可以在單個線程內可以並發的greenlet.greenlet的數目。當TCP server接受到請求之后，調用self.handle處理請求，源代碼在基類AsyncWorker，實現基本同SyncWorker。

　　 

references:

http://www.cnblogs.com/xybaby/p/6297147.html

http://www.cnblogs.com/xybaby/p/6370799.html

http://docs.gunicorn.org/en/latest/settings.html

http://sdiehl.github.io/gevent-tutorial/#groups-and-pools