def _patch_client_for_gevent(self):
try:
import gevent
import gevent.monkey
except ImportError:
gevent_enabled = False
else:
gevent_enabled = bool(gevent.monkey.saved)
if gevent_enabled:
self._Timeout = gevent.Timeout
self._sleep = gevent.sleep
self._get_value_event = lambda: gevent.event.AsyncResult()
else:
self._Timeout = ValueEventTimeout
self._sleep = lambda _: None
self._get_value_event = self._ensure_value_event
评论列表
文章目录