Неправильное поведение Thread с target=lambda?

Question

[Coder 1448]

Не знаю, баг ли это, или я не понимаю некоторых особенностей языка, но вот примеры.

from threading import Thread

threads = []
for i in range(2):
    threads.append(
        Thread(target=lambda: print(i))
    )

for t in threads:
    t.start()
    
# output:
# 1
# 1

from threading import Thread

threads = []
for i in range(2):
    Thread(target=lambda: print(i)).start()

# output:
# 0
# 1

from threading import Thread


threads = []
for i in range(2):
    threads.append(
        Thread(target=lambda i: print(i), args=[i])
    )

for t in threads:
    t.start()

# output:
# 0
# 1

Вопрос: почему первый код выдаёт не 0 1, а 1 1?

Answer 1

[Vindicar]

У тебя в первом случае тело потока (лямбда) захватывает через замыкание не значение i, а ссылку на i.
К моменту старта в первом случае i будет иметь другое значение.
Вот почему нужно использовать args - как во-втором случае. Тогда происходит захват значения - не через замыкание, а через параметр.

Comments

[Coder 1448]

Хорошо, но что мне делать если у меня функция принимает аргументом другую функцию? И мне нужно все это запулить в отдельный поток. Пример:

from threading import Thread


def safe(func):
    func()


threads = []
for i in range(2):
    threads.append(
        Thread(target=safe, args=[lambda: print(i)])
    )

for t in threads:
    t.start()

# output
# 1
# 1

[mkone112]

Coder 1448, не уверен зачем тебе, но как вариант - воспользоваться замыканием.

[Roman K]

Coder 1448, избавиться от лямбд

[Coder 1448]

Roman Kitaev, Избавился, решил сделать так, чтобы safe возвращала функцию, и её уже делать таргетом потока. Свою проблему решил.