(Многопоточность Python) Печать от 1 до 10 номеров поочередно, используя два потока

Question

Пожалуйста, помогите мне в разрешении ситуации ниже тупика при альтернативной печати чисел от 1 до 10, используя два потока.

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

from threading import *

c = Condition()

def thread_1():
    c.acquire()
    for i in range(1, 11, 2):
        print(i)
        c.notify()
        c.wait()
    c.release()
    c.notify()

def thread_2():
    c.acquire()
    c.wait()
    for i in range(2, 11, 2):
        print(i)
        c.notify()
        c.wait()
    c.release()


t1 = Thread(target=thread_1)
t2 = Thread(target=thread_2)

t1.start()
t2.start()

Answer 1

Редко бывает полезно, чтобы потоки перемещались в одном шаге друг с другом. Если вы действительно нуждаетесь в них, вы можете использовать два отдельных события, на которые ссылается Прудхви. Например:

from threading import Thread, Event

event_1 = Event()
event_2 = Event()

def func_1(ev1, ev2):
    for i in range(1, 11, 2):
        ev2.wait()  # wait for the second thread to hand over
        ev2.clear()  # clear the flag
        print('1')
        ev1.set()  # wake the second thread

def func_2(ev1, ev2):
    for i in range(2, 11, 2):
        ev2.set()  # wake the first thread
        ev1.wait()  # wait for the first thread to hand over
        ev1.clear()  # clear the flag
        print('2')

t1 = Thread(target=func_1, args=(event_1, event_2))
t2 = Thread(target=func_2, args=(event_1, event_2))

t1.start()
t2.start()

С точки зрения избежания тупика, на эту тему уже много написано. В вашем конкретном примере кода t1 сработает до t2 и достигнет c.wait(). t2 запустится и достигнет c.aquire(). Оба будут сидеть там до бесконечности. Избегать тупиковых ситуаций означает избегать ситуаций, когда оба потока ожидают другого.