File manager - Edit - /usr/share/doc/uwsgi-core/tests/ugevent.py
Back
import gevent import gevent.socket import sys import uwsgi from uwsgidecorators import * if 'gettotalrefcount' in sys.__dict__: REFCNT = True else: REFCNT = False @signal(17) def hello(signum): print("hello i am signal %d, i am here because the background job is finished" % signum) if REFCNT: print(sys.gettotalrefcount()) @timer(10) def ten_seconds(signum): print("10 seconds elapsed, signal %d raised" % signum) if REFCNT: print(sys.gettotalrefcount()) @filemon('/tmp') def tmp_modified(signum): print("/tmp has been touched, i am the greenlet %s running on worker %d" % (gevent.getcurrent(), uwsgi.worker_id())) if REFCNT: print(sys.gettotalrefcount()) def bg_task(): for i in range(1,10): print("background task", i) gevent.sleep(1) # task ended raise a signal !!! uwsgi.signal(17) def long_task(): for i in range(1,10): print(i) gevent.sleep() def application(e, sr): sr('200 OK', [('Content-Type','text/html')]) t = gevent.spawn(long_task) t.join() yield "sleeping for 3 seconds...<br/>" gevent.sleep(3) yield "done<br>" yield "getting some ips...<br/>" urls = ['www.google.com', 'www.example.com', 'www.python.org', 'projects.unbit.it'] jobs = [gevent.spawn(gevent.socket.gethostbyname, url) for url in urls] gevent.joinall(jobs, timeout=2) for j in jobs: yield "ip = %s<br/>" % j.value if REFCNT: print(sys.gettotalrefcount()) yield "%d" % sys.gettotalrefcount() # this task will goes on after request end gevent.spawn(bg_task)
| ver. 1.4 |
Github
|
.
| PHP 7.4.33 | Generation time: 0.26 |
proxy
|
phpinfo
|
Settings