ProcessWorker

class montreal_forced_aligner.utils.ProcessWorker(job_name, job_q, function, return_q, stopped)

Bases: Process

Multiprocessing function work

Parameters:

• job_name (int) – Integer number of job

• job_q (Queue) – Job queue to pull arguments from

• function (Callable) – Multiprocessing function to call on arguments from job_q

• return_dict (dict) – Dictionary for collecting errors

• stopped (Stopped) – Stop check

• return_info (dict[int, Any], optional) – Optional dictionary to fill if the function should return information to main thread

run()

Run through the arguments in the queue apply the function to them