我正在为我编写的一些分析代码构建一个界面，该界面执行一些SQL并处理查询结果。在这个分析代码中，有许多事件都被记录下来，我希望将这些日志暴露给用户。由于分析代码运行时间较长，并且我不想UI被阻塞，因此到目前为止，我通过将分析函数放入自己的线程中来实现这一点。
现在是一个简化的示例（完整脚本）：
但我似乎无法弄清楚如何从子进程中检索日志输出并将其传递给父进程以更新日志对话框。我已经阅读了几乎每一个关于此的SO问题，以及如何处理从多个进程写入单个日志文件的食谱示例，但我无法理解如何将这些想法适应我在这里尝试做的事情。
编辑
因此，为了弄清楚为什么我看到的行为与@eyllanesc不同，我添加了：
并且。
现在是一个简化的示例（完整脚本）：
import sys
import time
import logging
from PySide2 import QtCore, QtWidgets
def long_task():
logging.info('Starting long task')
time.sleep(3) # this would be replaced with a real task
logging.info('Long task complete')
class LogEmitter(QtCore.QObject):
sigLog = QtCore.Signal(str)
class LogHandler(logging.Handler):
def __init__(self):
super().__init__()
self.emitter = LogEmitter()
def emit(self, record):
msg = self.format(record)
self.emitter.sigLog.emit(msg)
class LogDialog(QtWidgets.QDialog):
def __init__(self, parent=None):
super().__init__(parent)
log_txt = QtWidgets.QPlainTextEdit(self)
log_txt.setReadOnly(True)
layout = QtWidgets.QHBoxLayout(self)
layout.addWidget(log_txt)
self.setWindowTitle('Event Log')
handler = LogHandler()
handler.emitter.sigLog.connect(log_txt.appendPlainText)
logger = logging.getLogger()
logger.addHandler(handler)
logger.setLevel(logging.INFO)
class Worker(QtCore.QThread):
results = QtCore.Signal(object)
def __init__(self, func, *args, **kwargs):
super().__init__()
self.func = func
self.args = args
self.kwargs = kwargs
def run(self):
results = self.func(*self.args, **self.kwargs)
self.results.emit(results)
class MainWindow(QtWidgets.QMainWindow):
def __init__(self):
super().__init__()
widget = QtWidgets.QWidget()
layout = QtWidgets.QHBoxLayout(widget)
start_btn = QtWidgets.QPushButton('Start')
start_btn.clicked.connect(self.start)
layout.addWidget(start_btn)
self.setCentralWidget(widget)
self.log_dialog = LogDialog()
self.worker = None
def start(self):
if not self.worker:
self.log_dialog.show()
logging.info('Run Starting')
self.worker = Worker(long_task)
self.worker.results.connect(self.handle_result)
self.worker.start()
def handle_result(self, result=None):
logging.info('Result received')
self.worker = None
if __name__ == '__main__':
app = QtWidgets.QApplication()
win = MainWindow()
win.show()
sys.exit(app.exec_())
这个代码可以正常工作，但我需要允许用户停止分析代码的执行。我已经查询过，似乎没有好的方法来优雅地中断线程，所以使用 multiprocessing 库似乎是可行的方法（无法重新编写分析代码以允许定期轮询，因为大部分时间都是等待查询返回结果）。通过使用 multiprocessing.Pool 和 apply_async 可以很容易地获得相同的功能，以非阻塞UI的方式执行分析代码。
例如，将上面的MainWindow替换为：
class MainWindow(QtWidgets.QMainWindow):
def __init__(self):
super().__init__()
widget = QtWidgets.QWidget()
layout = QtWidgets.QHBoxLayout(widget)
start_btn = QtWidgets.QPushButton('Start')
start_btn.clicked.connect(self.start)
layout.addWidget(start_btn)
self.setCentralWidget(widget)
self.log_dialog = LogDialog()
self.pool = multiprocessing.Pool()
self.running = False
def start(self):
if not self.running:
self.log_dialog.show()
logging.info('Run Starting')
self.pool.apply_async(long_task, callback=self.handle_result)
def handle_result(self, result=None):
logging.info('Result received')
self.running = False
但我似乎无法弄清楚如何从子进程中检索日志输出并将其传递给父进程以更新日志对话框。我已经阅读了几乎每一个关于此的SO问题，以及如何处理从多个进程写入单个日志文件的食谱示例，但我无法理解如何将这些想法适应我在这里尝试做的事情。
编辑
因此，为了弄清楚为什么我看到的行为与@eyllanesc不同，我添加了：
logger = logging.getLogger()
print(f'In Func: {logger} at {id(logger)}')
并且。
logger = logging.getLogger()
print(f'In Main: {logger} at {id(logger)}')
分别是long_task和Mainwindow.start。当我运行main.py时，会得到以下结果：
In Main: <RootLogger root (INFO)> at 2716746681984
In Func: <RootLogger root (WARNING)> at 1918342302352
这似乎是这个SO问题中所描述的解决方案
使用Queue和QueueHandler的这个想法作为解决方案与@eyllanesc的原始解决方案相似