class montreal_forced_aligner.corpus.multiprocessing.CorpusProcessWorker(name, job_q, return_q, stopped, finished_adding, speaker_characters, sample_rate)[source]#

Bases: Thread

Multiprocessing corpus loading worker

  • job_q (Queue) – Job queue for files to process

  • return_dict (dict) – Dictionary to catch errors

  • return_q (Queue) – Return queue for processed Files

  • stopped (Event) – Stop check for whether corpus loading should exit

  • finished_adding (Event) – Signal that the main thread has stopped adding new files to be processed


Run the corpus loading job