2

пишу утилитку столкнулся с проблемкой: при закрытии все просто напросто зависает... Я так понял не закрывается event loop в QThread. Так вот вопрос:

Подскажите как правильно закрыть event loop?

from PyQt5.QtCore import QThread, QObject, pyqtSlot
from PyQt5.QtWidgets import QMainWindow, QApplication
import asyncio
import websockets


class ExampleWorker(QObject):
    def __init__(self):
        super().__init__()


    @pyqtSlot()
    def start(self):
        self.loop = asyncio.new_event_loop()
        asyncio.set_event_loop(self.loop)
        self.loop.run_until_complete(websockets.serve(self.echo, 'localhost', 8765))
        self.loop.run_forever()


    async def echo(self, websocket, path):
        async for message in websocket:
            await websocket.send(message)


class Example(QMainWindow):

    def __init__(self):
        self.app = QApplication([])
        super().__init__()

        self.obj = ExampleWorker()
        self.thread = QThread()
        self.obj.moveToThread(self.thread)
        self.thread.started.connect(self.obj.start)
        self.thread.start()

        self.show()
        self.app.exec_()


    def closeEvent(self, event):
        self.thread.quit()
        self.thread.wait()


Example()

1 ответ 1

2

loop.stop() пробовали в слот terminate?

А ещё можно заставить asyncio работать вместе с qt.

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.