#!/usr/bin/env python
# -*- coding: utf-8 -*-

import threading
import time



def customer(cond):
t = threading.currentThread()
with cond:
# wait()方法創建了一個名為waiter的鎖，并且設置鎖的狀態為locked。這個waiter鎖用于線程間的通訊
cond.wait()
print '{}: Resource is available to consumer'.format(t.name)

def producer(cond):
t = threading.currentThread()
with cond:
print '{}: Making resource available'.format(t.name)
cond.notifyAll()


if __name__ == "__main__":
cond = threading.Condition()
c1 = threading.Thread(target=customer, args=(cond,), name='c1')
c2 = threading.Thread(target=customer, args=(cond,), name='c2')
p1 = threading.Thread(target=producer, args=(cond,), name='p1')

c1.start()
c2.start()
p1.start()


print 'Main end'

轉載于:https://www.cnblogs.com/zejin2008/p/7586683.html

總結

以上是生活随笔為你收集整理的python多线程同步机制condition的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。