Функция принимает список чисел и для каждого делает список из чисел на которые оно делится без остатка. Я пытаюсь реализовать передачу нескольких чисел, но получаю очень много ошибок. Объясните как можно в моем случае реализовать многопроцессорность, что я делаю неправильно и нужно ли использовать RLock если я уже использую Manager.list()?
import time
from multiprocessing import cpu_count, Process, Manager
def factorize(factors: list, shared_value: list, *number):
for num in number:
for i in range(1, num+1):
if num % i == 0:
factors.append(i)
shared_value.append(factors)
return shared_value
if __name__ == '__main__':
cpu_cores = cpu_count()
start_time = time.time()
with Manager() as manager:
processes = []
shared_list = manager.list()
shared_factors = manager.list()
for _ in range(cpu_cores+1):
pr = Process(target=factorize, args=(shared_factors, shared_list, 128, 255, 99999, 10651060, ))
pr.start()
processes.append(pr)
[el.join() for el in processes]
end_time = time.time()
running_time = end_time - start_time
print(list(shared_list))
print('Time:', running_time)
assert shared_list[0] == [1, 2, 4, 8, 16, 32, 64, 128]
assert shared_list[1] == [1, 3, 5, 15, 17, 51, 85, 255]
assert shared_list[2] == [1, 3, 9, 41, 123, 271, 369, 813, 2439, 11111, 33333, 99999]
assert shared_list[3] == [1, 2, 4, 5, 7, 10, 14, 20, 28, 35, 70, 140, 76079, 152158, 304316, 380395, 532553, 760790,
1065106, 1521580, 2130212, 2662765, 5325530, 10651060]