spinetoolbox.qthread_pool_executor

Qt-based thread pool executor.

Module Contents

Classes

_CustomQSemaphore
QtBasedQueue	A Qt-based clone of queue.Queue.
QtBasedFuture	A Qt-based clone of concurrent.futures.Future.
QtBasedThread	A Qt-based clone of threading.Thread.
QtBasedThreadPoolExecutor	A Qt-based clone of concurrent.futures.ThreadPoolExecutor
SynchronousExecutor

Functions

_set_future_result_and_exc(future, fn, *args, **kwargs)

exception spinetoolbox.qthread_pool_executor.TimeOutError

Bases: Exception

An exception to raise when a timeouts expire

Initialize self. See help(type(self)) for accurate signature.

class spinetoolbox.qthread_pool_executor._CustomQSemaphore

Bases: PySide6.QtCore.QSemaphore

tryAcquire(n, timeout=None)

class spinetoolbox.qthread_pool_executor.QtBasedQueue

A Qt-based clone of queue.Queue.

put(item)

get(timeout=None)

class spinetoolbox.qthread_pool_executor.QtBasedFuture

A Qt-based clone of concurrent.futures.Future.

set_result(result)

set_exception(exc)

result(timeout=None)

exception(timeout=None)

add_done_callback(callback)

class spinetoolbox.qthread_pool_executor.QtBasedThread(target=None, args=())

Bases: PySide6.QtCore.QThread

A Qt-based clone of threading.Thread.

run()

class spinetoolbox.qthread_pool_executor.QtBasedThreadPoolExecutor(max_workers=None)

A Qt-based clone of concurrent.futures.ThreadPoolExecutor

submit(fn, *args, **kwargs)

_spawn_thread()

_do_work()

shutdown()

class spinetoolbox.qthread_pool_executor.SynchronousExecutor

submit(fn, *args, **kwargs)

shutdown()

spinetoolbox.qthread_pool_executor._set_future_result_and_exc(future, fn, *args, **kwargs)