multithreading_simple_.py

"""
Multithreading simple
=====================

.. tags:: interactivity
"""

import time

from qtpy.QtWidgets import QApplication, QHBoxLayout, QLabel, QWidget

from napari.qt import thread_worker


@thread_worker
def long_running_function():
    """Just a long running function, most like viewer.update."""
    time.sleep(2)  # long function
    return 'finished!'


def create_widget():
    widget = QWidget()
    layout = QHBoxLayout()
    widget.setLayout(layout)
    widget.status = QLabel('ready...')
    layout.addWidget(widget.status)
    widget.show()
    return widget


if __name__ == '__main__':
    app = QApplication([])
    wdg = create_widget()

    # call decorated function
    # By default, @thread_worker-decorated functions do not immediately start
    worker = long_running_function()
    # Signals are best connected *before* starting the worker.
    worker.started.connect(lambda: wdg.status.setText('worker is running...'))
    worker.returned.connect(lambda x: wdg.status.setText(f'returned {x}'))

    # # Connections may also be passed directly to the decorated function.
    # # The above syntax is equivalent to:
    # worker = long_running_function(
    #     _connect={
    #         'started': lambda: wdg.status.setText("worker is running..."),
    #         'returned': lambda x: wdg.status.setText(f"returned {x!r}"),
    #     }
    # )

    worker.start()

    app.exec_()