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, который мне нужен.
    – slx0009
    24 ноя 2021 в 13:30
  • И как можно исправить передачу аргументов?
    – slx0009
    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 that you have read and understand our privacy policy and code of conduct.

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