Многопроцессорность не запускается - PullRequest
Новая
       8

Многопроцессорность не запускается

0 голосов
/ 28 мая 2020

Я хочу, чтобы 15 воркеры обработали какой-то текст. Текст находится в файле. Я помещаю пути к этим файлам в queue и передаю этот queue (среди других ресурсов, но я оставил их для целей отладки) моей функции. Однако функция никогда не вводится. Почему? 

from multiprocessing import get_context, Queue, Manager

paths = ["path1", "path2", "path3", ...]
amount_prcs = 15

def start_process(test):
    print(test)

if __name__ == '__main__':

    with get_context('spawn').Pool(processes=amount_prcs) as pool:

        m = Manager()
        queue = m.Queue()
        for path in paths:
            queue.put(path)

        for i in range(amount_prcs):
            print("here1!")
            num = int(i / (amount_prcs / amount_trainers))
            pool.apply_async(start_process, "test")
...