многопоточность для одновременного просмотра папок - PullRequest
Новая
       6

многопоточность для одновременного просмотра папок

0 голосов
/ 06 июня 2018

В настоящее время я пытаюсь иметь 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 секунд ... или как реализовать это

1 Ответ

0 голосов
/ 06 июня 2018

Кажется, что вы скопировали код и не поняли, как он работает, например, signals не определено, и очевидно, что сигналы - это объект другого класса, задачей которого является предоставление сигналов соединения нас другой стороны, в @pyqtSlot есть опечатка, она должна быть @pyqtSlot().С другой стороны, окно никогда не будет отображаться, так как вы не вызываете метод show(), и для последней, главной ошибки, является то, что вы оцениваете функцию монитора в главном потоке, рабочий должен передать вамфункция без оценки и рядом с аргументами этой функции, поэтому вы можете вызывать ее во вторичном потоке. 

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_())
...