Многопроцессорная обработка не выводит результат с помощью Python - PullRequest
Новая
       17

Многопроцессорная обработка не выводит результат с помощью Python

0 голосов
/ 10 марта 2019

Я пытаюсь применить многопроцессорность к функции.Функция печати есть, но она не отображается. 

import json
import os
import multiprocessing as mp

def file_subreddit_comments(rfname):
    wfname = rfname + "_ext_com.txt"
    return wfname       

defaultFilePath = r'D:\Users\Jonathan\Desktop\Reddit Data\Run Comments\\'
directory = os.fsencode(defaultFilePath)

list_submission_id = []
submission_id_file = r'D:\Users\Jonathan\Desktop\Reddit Data\Manipulated Data-09-03-19-Final\UniqueIDSubmissionsList-09-03-2019.txt'
with open(submission_id_file, "r", encoding="utf8") as sif:
    for i, l in enumerate(sif):
        list_submission_id.append(l.rstrip())

new_submission_list_dir = []
for file in os.listdir(directory):
     filename = os.fsdecode(file)
     comment_path_read = defaultFilePath + filename
     new_submission_list_dir.append(comment_path_read)  

with mp.Pool(mp.cpu_count()-1) as p:
    results = p.map(file_subreddit_comments, [row for row in new_submission_list_dir])

print(results)

new_submission_list_dir содержит список всех файлов, передаваемых в функцию file_subreddit_comments.Я некоторое время запускал код, но ничего не печаталось с print(results)

...