(Multi-Threading Python) 交替打印1到10个数字,使用两个线程
(Multi-Threading Python) Print 1 to 10 numbers alternatively, using two threads
请帮助我解决以下死锁情况,同时使用两个线程交替打印 1 到 10 个数字。
请告诉我在多线程中避免死锁情况的最佳做法python。
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()
让线程彼此同步移动很少有用。如果你真的需要他们,你可以使用两个单独的事件,正如 Prudhvi 所暗示的那样。例如:
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()
。两者都将无限期地坐在那里。避免死锁意味着避免两个线程都等待另一个线程的情况。
请帮助我解决以下死锁情况,同时使用两个线程交替打印 1 到 10 个数字。
请告诉我在多线程中避免死锁情况的最佳做法python。
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()
让线程彼此同步移动很少有用。如果你真的需要他们,你可以使用两个单独的事件,正如 Prudhvi 所暗示的那样。例如:
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()
。两者都将无限期地坐在那里。避免死锁意味着避免两个线程都等待另一个线程的情况。