用于同时观看文件夹的多线程

Question

目前我正在尝试让 2 个按钮（几乎）同时运行。问题在于下面的代码，每个按钮都可以正常运行，但是当两个都被检查时，只有第一个运行。

import sys
from PyQt4.QtGui import *
from PyQt.QtCore import *
import os
import time
import traceback

class Worker(QRunnable):
    def __init__(self, fn, *args, **kwargs):
        super(Worker, self).__init__()

        self.fn = fn
        self.args = args
        self.kwargs = kwargs


    @pyqtSlot
    def run(self):
        try:
            result = self.fn(*self.args, **self.kwargs)
        except:
            traceback.print_exc()
            exctype, value = sys.exc_info()[:2]
            self.signals.error.emit((exctype, value,  
                                    traceback.format_exc()))
        else:
            self.signals.result.emit(result)
        finally:
            self.signals.finished.emit()

class MainWindow(QMainWindow):
    def __init__(self, *args, **kwargs):
        super(MainWindow, self).__init__(*args, **kwargs)

        layout = QVBoxLayout()

        path =  "Paths to watch"
        path2 = "Paths to watch"

        self.b = QPushButton("Button1")
        self.b.setCheckable(True)
        self.b.pressed.connect(lambda: self.watcher(path))

        self.b2 = QPushButton("Button1")
        self.b2.setCheckable(True)
        self.b2.pressed.connect(lambda: self.watcher(path2))

        layout.addWidget(self.b)
        layout.addWidget(self.b2)

        w = QWidget()
        w.setLayout(layout)
        self.setCentralWidget(w)

        self.threadpool = QThreadPool()

    def watcher(self, s):
        worker = Worker(self.monitor(s))
        self.threadpool.start(worker)

    def monitor(self, s):
        before = dict([(f, None) for f in os.listdir(s)])
        while 1:
            QCoreApplication.processEvents()
            after = dict([(f, None) for f in os.listdir(s)])
            added = [f for f in after if not f in before]
            removed = [f for f in before if not f in after]
            if added: print "Added: ", ", ".join(added)
            if removed: print "Deleted: ", ", ".join(removed)
            before = after

app = QApplication([])
window = MainWindow()
app.exec_()

不确定我是否需要分配线程，或者我是否可以通过某种方式让函数每 x 秒使用一个计时器更新 GUI ......或者如何实现它

Answer 1

好像你复制了代码，你没有理解它的操作，例如signals没有定义，很明显signals是另一个类的对象，它的任务是提供连接信号，on另一方面，@pyqtSlot 中存在印刷错误，它必须是@pyqtSlot()。另一方面，由于您没有调用show() 方法，因此该窗口将永远不会显示，而对于最后一个错误，主要错误是您正在主线程中评估监视器功能，Worker 需要您通过无需评估的函数，并在该函数的参数旁边，因此您可以在辅助线程中调用它。

import sys
import os
import time
import traceback

from PyQt4.QtGui import *
from PyQt4.QtCore import *


class SignalHelper(QObject):
    error = pyqtSignal(tuple)
    result = pyqtSignal(object)
    finished = pyqtSignal()

class Worker(QRunnable):
    def __init__(self, fn, *args, **kwargs):
        super(Worker, self).__init__()

        self.fn = fn
        self.args = args
        self.kwargs = kwargs
        self.signals = SignalHelper()

    @pyqtSlot()
    def run(self):
        try:
            result = self.fn(*self.args, **self.kwargs)
        except:
            traceback.print_exc()
            exctype, value = sys.exc_info()[:2]
            self.signals.error.emit((exctype, value,  
                                    traceback.format_exc()))
        else:
            self.signals.result.emit(result)
        finally:
            self.signals.finished.emit()

class MainWindow(QMainWindow):
    def __init__(self, *args, **kwargs):
        super(MainWindow, self).__init__(*args, **kwargs)

        layout = QVBoxLayout()

        path =  "Paths to watch"
        path2 = "Paths to watch"

        self.b = QPushButton("Button1")
        self.b.setCheckable(True)
        self.b.pressed.connect(lambda: self.watcher(path))

        self.b2 = QPushButton("Button1")
        self.b2.setCheckable(True)
        self.b2.pressed.connect(lambda: self.watcher(path2))

        layout.addWidget(self.b)
        layout.addWidget(self.b2)

        w = QWidget()
        w.setLayout(layout)
        self.setCentralWidget(w)

        self.threadpool = QThreadPool()

    def watcher(self, s):
        worker = Worker(self.monitor, s)
        self.threadpool.start(worker)

    def monitor(self, s):
        before = dict([(f, None) for f in os.listdir(s)])
        while True:
            after = dict([(f, None) for f in os.listdir(s)])
            added = [f for f in after if not f in before]
            removed = [f for f in before if not f in after]
            if added: print("Added: ", ", ".join(added))
            if removed: print("Deleted: ", ", ".join(removed))
            before = after

if __name__ == '__main__':
    app = QApplication(sys.argv)
    window = MainWindow()
    window.show()
    sys.exit(app.exec_())