Madiator2011/lbry-sdk
1
0
Fork 0
forked from LBRYCommunity/lbry-sdk
Code Pull requests Activity

fix android executor

Browse source
This commit is contained in:
Jack Robison 2020-03-17 10:27:27 -04:00
parent 36243d15cc
commit 9769829b72
No known key found for this signature in database
GPG key ID: DF25C68FE0239BB2
1 changed files with 5 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
lbry/wallet/database.py
View file

@ -51,8 +51,11 @@ def run_read_only_fetchone(sql, params):
raise
READER_EXECUTOR_CLASS = ThreadPoolExecutor if 'ANDROID_ARGUMENT' in os.environ else ProcessPoolExecutor
class AIOSQLite:
reader_executor: ProcessPoolExecutor
reader_executor: READER_EXECUTOR_CLASS
def __init__(self):
# has to be single threaded as there is no mapping of thread:connection
@ -73,7 +76,7 @@ class AIOSQLite:
db.writer_connection = sqlite3.connect(path, *args, **kwargs)
readers = max(os.cpu_count() - 2, 2)
db.reader_executor = ProcessPoolExecutor(
db.reader_executor = READER_EXECUTOR_CLASS(
max_workers=readers, initializer=initializer, initargs=(path, )
)
await asyncio.get_event_loop().run_in_executor(db.writer_executor, _connect_writer)