queue.py

mport threading
import time
from queue import Queue
import sys
from os import listdir
from collections import Counter

q = Queue()
directory = sys.argv[1]
files = listdir(directory)
# print(files)
# f = files[0]
def create_dict_from_email(path):
    text = open(path, errors='ignore').read()
    d = Counter(text.split())
    print(threading.current_thread().name)
    q.put(d)

# sequential
# for f in files:
#     d = create_dict_from_email(directory + '/' + f)
#     print(d)

threads = []
for f in files:
    p = directory + '/' + f
    t = threading.Thread(target=create_dict_from_email, args=(p,))
    threads.append(t)
    t.start()

from functools import reduce
results = []
for t in threads:
    # waits for all threads to finish
    t.join()
    results.append(q.get())
#print(results)

r = reduce(lambda x,y: x+y, results)
print(r)