main.py
у приложение для Windows с Pyside2. В связи с тем, как я использую многопоточность, мне приходится взаимодействовать с одной и той же базой данных Sqlite3 в нескольких потоках. Я создал линию <100Минимальный, полный, проверяемый пример это почти идентично повторяет проблему.
Проблема: Я в настоящее время используюмодуль pynput чтобы отслеживать активность клавиш в фоновом режиме после нажатия кнопки, в то время как графический интерфейс Qt не в фокусе для сочетания клавиш «j» + «k». После нажатия комбинации горячих клавиш делается снимок экрана, изображение обрабатывается с помощью OCR и сохраняется в базе данных вместе с текстом OCR. Путь к изображению отправляется через серию подключенных сигналов в основной поток GUI. Ключевой мониторинг происходит в другомQThread
для предотвращения мониторинга ключа и обработки изображения от запуска основного цикла событий Qt. Как только QThread запускается и испускает сигнал запуска, я вызываюmonitor_for_hot_key_combo
функция в экземпляре key_monitor, которая создаетlistener
какthreading.Thread
, которому назначены функции-члены key_monitoron_release
а такжеon_press
как обратные вызовы, которые вызываются при каждом нажатии клавиши.
Вот в чем проблема. Эти обратные вызовы взаимодействуют сimageprocessing_obj
экземплярimage_process
класс в другом потоке, чем класс был создан в. Поэтому, когдаimage_process
Функции-члены взаимодействуют с тем, что используют базу данных SQlite, они делают это в отдельном потоке, в котором было создано соединение с базой данных.Теперь SQLite "может безопасно использоваться несколькими потоками при условии, чтони одно соединение с базой данных не используется одновременно в двух или более темах ". Чтобы разрешить это, вы должны установитьcheck_same_thread
аргумент в пользуsqlite3.connect()
ложно. Тем не менее, я бы по возможности избегал многопоточного доступа к базе данных, чтобы предотвратить неопределенное поведение.
Возможное решение: Мне было интересно, если два потока, обаthreading.Thread
а такжеQThread
не нужны, и все это можно сделать в потоке Pynput. Однако я не могу понять, как просто использовать поток Pynput, все еще имея возможность отправлять сигналы обратно в основной цикл событий Qt.
qtui.py
from PySide2 import QtCore, QtWidgets
from PySide2.QtCore import *
import HotKeyMonitor
class Ui_Form(object):
def __init__(self):
self.worker = None
def setupUi(self, Form):
Form.setObjectName("Form")
Form.resize(400, 300)
self.pressbutton = QtWidgets.QPushButton(Form)
self.pressbutton.setObjectName("PushButton")
self.pressbutton.clicked.connect(self.RunKeyMonitor)
self.retranslateUi(Form)
QtCore.QMetaObject.connectSlotsByName(Form)
def retranslateUi(self, Form):
Form.setWindowTitle(QtWidgets.QApplication.translate("Form", "Form", None, -1))
self.pressbutton.setText(QtWidgets.QApplication.translate("Form", "Press me", None, -1))
def RunKeyMonitor(self):
self.Thread_obj = QThread()
self.HotKeyMonitor_Obj = HotKeyMonitor.key_monitor()
self.HotKeyMonitor_Obj.moveToThread(self.Thread_obj)
self.HotKeyMonitor_Obj.image_processed_km.connect(self.print_OCR_result)
self.Thread_obj.started.connect(self.HotKeyMonitor_Obj.monitor_for_hotkey_combo)
self.Thread_obj.start()
def print_OCR_result(self, x):
print("Slot being called to print image path string")
print(x)
if __name__ == "__main__":
import sys
app = QtWidgets.QApplication(sys.argv)
Form = QtWidgets.QWidget()
ui = Ui_Form()
ui.setupUi(Form)
Form.show()
sys.exit(app.exec_())
HotKeyMonitor.py
from pynput import keyboard
from PySide2.QtCore import QObject, Signal
import imageprocess
class key_monitor(QObject):
image_processed_km = Signal(str)
def __init__(self):
super().__init__()
self.prev_key = None
self.listener = None
self.imageprocessing_obj = imageprocess.image_process()
self.imageprocessing_obj.image_processed.connect(self.image_processed_km.emit)
def on_press(self,key):
pass
def on_release(self,key):
if type(key) == keyboard._win32.KeyCode:
if key.char.lower() == "j":
self.prev_key = key.char.lower()
elif key.char.lower() == "k" and self.prev_key == "j":
print("key combination j+k pressed")
self.prev_key = None
self.imageprocessing_obj.process_image()
else:
self.prev_key = None
def stop_monitoring(self):
self.listener.stop()
def monitor_for_hotkey_combo(self):
with keyboard.Listener(on_press=self.on_press, on_release = self.on_release) as self.listener:self.listener.join()
imageprocess.py
import uuid,os,sqlite3,pytesseract
from PIL import ImageGrab
from PySide2.QtCore import QObject, Signal
class image_process(QObject):
image_processed = Signal(str)
def __init__(self):
super().__init__()
self.screenshot = None
self.db_connection = sqlite3.connect("testdababase.db", check_same_thread=False)
self.cursor = self.db_connection.cursor()
self.cursor.execute("CREATE TABLE IF NOT EXISTS testdb (OCRstring text, filepath text)")
def process_image(self):
self.screenshot = ImageGrab.grab()
self.screenshot_path = os.getcwd() + "\\" + uuid.uuid4().hex + ".jpg"
self.screenshot.save(self.screenshot_path )
self.ocr_string = pytesseract.image_to_string(self.screenshot)
self.cursor.execute("INSERT INTO testdb (OCRstring, filepath) VALUES (?,?)",(self.ocr_string, self.screenshot_path))
self.image_processed.emit(self.screenshot_path)