forked from LBRYCommunity/lbry-sdk
fix test
This commit is contained in:
parent
7945e1ea3c
commit
9d5760d899
1 changed files with 2 additions and 2 deletions
|
@ -6,7 +6,7 @@
|
||||||
# and warranty status of this software.
|
# and warranty status of this software.
|
||||||
|
|
||||||
"""Mempool handling."""
|
"""Mempool handling."""
|
||||||
|
import os
|
||||||
import asyncio
|
import asyncio
|
||||||
import itertools
|
import itertools
|
||||||
import time
|
import time
|
||||||
|
@ -106,7 +106,7 @@ class MemPool:
|
||||||
# Prevents mempool refreshes during fee histogram calculation
|
# Prevents mempool refreshes during fee histogram calculation
|
||||||
self.lock = asyncio.Lock()
|
self.lock = asyncio.Lock()
|
||||||
self.wakeup = asyncio.Event()
|
self.wakeup = asyncio.Event()
|
||||||
self.executor = ThreadPoolExecutor(4)
|
self.executor = ThreadPoolExecutor(max(os.cpu_count() - 1, 1))
|
||||||
|
|
||||||
async def _logging(self, synchronized_event):
|
async def _logging(self, synchronized_event):
|
||||||
"""Print regular logs of mempool stats."""
|
"""Print regular logs of mempool stats."""
|
||||||
|
|
Loading…
Add table
Reference in a new issue