jingrow/gunicorn
1
0
Fork 0
mirror of https://github.com/frappe/gunicorn.git synced 2026-01-14 11:09:11 +08:00
Code Issues Packages Projects Releases Wiki Activity

pool!

Browse Source
This commit is contained in:
benoitc 2010-06-10 21:44:43 +02:00
parent ff5adc46a4
commit 5ea58c1af2
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
gunicorn/workers/ggevent2.py
View File

@ -29,6 +29,10 @@ class GEvent2Worker(Worker):
'wsgi.run_once': False 'wsgi.run_once': False
} }
def __init__(self, *args, **kwargs):
super(GEvent2Worker, self).__init__(*args, **kwargs)
self.worker_connections = self.cfg.worker_connections
self.pool = None
@classmethod @classmethod
def setup(cls): def setup(cls):
@ -36,8 +40,7 @@ class GEvent2Worker(Worker):
monkey.patch_all() monkey.patch_all()
def handle_request(self, req): def handle_request(self, req):
gevent.getcurrent() self.pool.spawn(self.handle, req)
gevent.spawn(self.handle, req)
def handle(self, req): def handle(self, req):
handle = wsgi.WSGIHandler(req) handle = wsgi.WSGIHandler(req)
@ -55,6 +58,8 @@ class GEvent2Worker(Worker):
http = core.http() http = core.http()
http.set_gencb(self.handle_request) http.set_gencb(self.handle_request)
self.pool = Pool(self.worker_connections)
self.application = self.wsgi self.application = self.wsgi
acceptor = gevent.spawn(http.accept, self.socket.fileno()) acceptor = gevent.spawn(http.accept, self.socket.fileno())
@ -67,7 +72,7 @@ class GEvent2Worker(Worker):
gevent.kill(acceptor) gevent.kill(acceptor)
break break
gevent.sleep(0.1) gevent.sleep(0.1)
pool.join(timeout=self.timeout)
except KeyboardInterrupt: except KeyboardInterrupt:
pass pass