We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e85e22c commit fd06d4eCopy full SHA for fd06d4e
par.py
@@ -1,8 +1,17 @@
1
import asyncio
2
import concurrent
3
+import logging
4
+
5
+logger = logging.getLogger('par')
6
7
thread_pool = concurrent.futures.ThreadPoolExecutor()
8
event_loop = asyncio.get_event_loop()
9
+event_loop.set_default_executor(thread_pool)
10
11
+def event_loop_exeception_handler(loop, context):
12
+ if 'exception' in context:
13
+ logger.info(context['exception'])
14
+event_loop.set_exception_handler(event_loop_exeception_handler)
15
16
def async_execute(func, *args, **kw):
17
return asyncio.wrap_future(thread_pool.submit(func, *args, **kw), loop=event_loop)
0 commit comments