`threads`

Module Contents

Classes

`ProcessThread`	Worker thread
`WorkerFitLifetimes`	A QRunnable class to create a worker thread for fitting lifetimes.
`WorkerGrouping`
`WorkerResolveLevels`	A QRunnable class to create a worker thread for resolving levels.
`WorkerBinAll`	A QRunnable class to create a worker thread for binning all the data.

Attributes

logger

threads.logger = "'threads'"[source]

class threads.ProcessThread(num_processes: int = None, tasks: processes.ProcessTask | List[processes.ProcessTask] = None, signals: signals.ProcessThreadSignals = None, worker_signals: signals.WorkerSignals = None, task_buffer_size: int = None, status_message: str = None, temp_dir: tempfile.TemporaryDirectory = None)[source]

Bases: PyQt5.QtCore.QRunnable

Worker thread

property status_message[source]

_processes = '[]'[source]

_manager[source]

task_queue[source]

result_queue[source]

feedback_queue[source]

force_stop = 'False'[source]

is_running = 'False'[source]

_status_message = 'None'[source]

_temp_dir = 'None'[source]

task_buffer_size = 'None'[source]

tasks = '[]'[source]

results = '[]'[source]

add_tasks(tasks: processes.ProcessTask | List[processes.ProcessTask])[source]

add_tasks_from_methods(objects: object | List[object], method_name: str, args=None)[source]

run(num_processes: int = None)[source]: Your code goes in this function

check_fbk_queue()[source]

class threads.WorkerFitLifetimes(fit_lifetimes_func, data, currentparticle, fitparam, mode: str, resolve_selected=None)[source]

Bases: PyQt5.QtCore.QRunnable

A QRunnable class to create a worker thread for fitting lifetimes.

mode[source]

signals[source]

fit_lifetimes_func[source]

resolve_selected = 'None'[source]

data[source]

currentparticle[source]

fitparam[source]

run() → None[source]: The code that will be run when the thread is started.

class threads.WorkerGrouping(data: smsh5.H5dataset, grouping_func, mode: str, currentparticle: smsh5.Particle = None, group_selected=None)[source]

Bases: PyQt5.QtCore.QRunnable

mode[source]

signals[source]

grouping_func[source]

group_selected = 'None'[source]

data[source]

currentparticle = 'None'[source]

run() → None[source]: The code that will be run when the thread is started.

class threads.WorkerResolveLevels(resolve_levels_func, conf: int | float, data: smsh5.H5dataset, currentparticle: smsh5.Particle, mode: str, resolve_selected=None, end_time_s=None)[source]