From 1670d969083bc3cf5bbc76426872d1e4dd46f6cf Mon Sep 17 00:00:00 2001 From: shortcutme Date: Sat, 30 Nov 2019 02:12:33 +0100 Subject: [PATCH] Execute db commit in separate thread --- src/Db/Db.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/Db/Db.py b/src/Db/Db.py index a7b8fc23..60fe3726 100644 --- a/src/Db/Db.py +++ b/src/Db/Db.py @@ -14,7 +14,10 @@ from Debug import Debug from .DbCursor import DbCursor from util import SafeRe from util import helper +from util import ThreadPool +from Config import config +thread_pool_db = ThreadPool.ThreadPool(config.threads_db) opened_dbs = [] @@ -115,6 +118,7 @@ class Db(object): self.connect() return self.cur.execute(query, params) + @thread_pool_db.wrap def commit(self, reason="Unknown"): if self.progress_sleeping: self.log.debug("Commit ignored: Progress sleeping")