0
def method(args, num):
    ...

# Массив чисел от 50 до 100
nums = [x for x in range(50, 100)]
# Создаю массивы с агрументами и каждым числом
map_args = [(args, a) for a in nums]
with concurrent.futures.ThreadPoolExecutor(max_workers=num_threads) as exe:
    exe.map(method, map_args)

Почему-то не работает, сразу же завершается работа с кодом 0. Не могу понять почему?
Может как-то иначе аргументы в метод передавать? exe.map(method, map_args)

2 ответа 2

1

Вам нужно ещё проитерироваться по результатам маппинга:

result = exe.map(method, map_args)
for res in result:
   print(res)

С передачей аргументов у вас, кажется, тоже проблемы, но главное то, что вы не потребляете результаты вызова.

3
  • А как-то можно без итерирования обойтись? В result все None, кроме того единственного res, который мне нужен.
    – sln
    24 ноя 2021 в 13:30
  • И как можно исправить передачу аргументов?
    – sln
    24 ноя 2021 в 13:30
  • Ну можно просто взять list(exe.map) и оно само проитерируется с помощью list. А насчёт аргументов, я не знаю, как сделать красиво, но вы можете оставить один аргумент у функции - туда будет попадать кортеж из переданных значений. Можете распаковать этот кортеж и получить таким образом переменные.
    – CrazyElf
    24 ноя 2021 в 15:34
0

Ошибка в том, что метод принимает 2 аргумента args и num, а я передаю только 1 - map_args. Как передавать 2 аргумента я не знаю, но можно все еще передавать map_args, заменив method(args, num) на method(data), и распаковывать data - args, num = data.

def method(data):
    args, num = data
    ...

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge you have read our privacy policy.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.