Some asyncio tweaks.
This commit is contained in:
parent
7b5613ce77
commit
ac85bea111
@ -33,16 +33,10 @@ _loop_kicking_operator_running = False
|
|||||||
|
|
||||||
|
|
||||||
def setup_asyncio_executor():
|
def setup_asyncio_executor():
|
||||||
"""Sets up AsyncIO to run on a single thread.
|
"""Sets up AsyncIO to run properly on each platform."""
|
||||||
|
|
||||||
This ensures that only one Pillar HTTP call is performed at the same time. Other
|
|
||||||
calls that could be performed in parallel are queued, and thus we can
|
|
||||||
reliably cancel them.
|
|
||||||
"""
|
|
||||||
import sys
|
import sys
|
||||||
|
|
||||||
executor = concurrent.futures.ThreadPoolExecutor()
|
|
||||||
|
|
||||||
if sys.platform == 'win32':
|
if sys.platform == 'win32':
|
||||||
asyncio.get_event_loop().close()
|
asyncio.get_event_loop().close()
|
||||||
# On Windows, the default event loop is SelectorEventLoop, which does
|
# On Windows, the default event loop is SelectorEventLoop, which does
|
||||||
@ -52,6 +46,8 @@ def setup_asyncio_executor():
|
|||||||
asyncio.set_event_loop(loop)
|
asyncio.set_event_loop(loop)
|
||||||
else:
|
else:
|
||||||
loop = asyncio.get_event_loop()
|
loop = asyncio.get_event_loop()
|
||||||
|
|
||||||
|
executor = concurrent.futures.ThreadPoolExecutor(max_workers=10)
|
||||||
loop.set_default_executor(executor)
|
loop.set_default_executor(executor)
|
||||||
# loop.set_debug(True)
|
# loop.set_debug(True)
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user