Есть код:
username = 'ivan'
parted_list = [[1],[2],[3],[4],[5],[6],[7],[8],[9],[10]]
my_function(username,parted_list):
print('yep!')
p = multiprocessing.Pool()
thread_number = 0
for i in range(10):
work = p.map(lambda f: f(username,parted_list[thread_number]),[my_function])
thread_number +=1
p.close()
p.join()
в чем проблема: код работает, но потоки запускаются по очереди, ввиду цикла for. Чтобы они запустились параллельно, как я понимаю надо вот эту строку:
work = p.map(lambda f: f(username,parted_list[thread_number]),[my_function])
переделать на эту:
work = p.map(lambda f: f(username,parted_list[thread_number]),[my_function,my_function,my_function,my_function,my_function,my_function,my_function,my_function,my_function,my_function])
и убрать цикл for
.
НО! для каждой функции должен быть разный thread_number
, что без цикла получить- я не знаю как. Есть решение этой проблемы? Желательно еще в дзене Python, чтобы не писать my_function
10 раз, а сделать это более лаконично.