CorpusProcessWorker

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

Bases: Thread

Multiprocessing corpus loading worker

Variables:

• 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()

Run the corpus loading job