# -*- coding:utf-8 -*-import threading
import random
import timegMoney = 1000
gLock = threading.Lock()
gTotalTimes = 10
gTime = 0
class Producer(threading.Thread):def run(self):global gMoneyglobal gTimewhile True:money = random.randint(100,1000)gLock.acquire()if gTime >= gTotalTimes:gLock.release()breakgMoney += moneyprint "%s生产了%d元钱，剩余%d元钱" % (threading.current_thread(),money,gMoney)gTime += 1gLock.release()time.sleep(0.5)class Consumer(threading.Thread):def run(self):global gMoneywhile True:money = random.randint(100,1000)gLock.acquire()if gMoney >= money:gMoney -= moneyprint "%s消费者，消费了%d元，还剩%d元" %(threading.current_thread(),money,gMoney)else:if gTime >= gTotalTimes:gLock.release()breakgLock.release()time.sleep(0.5)def main():for x in range(5):t = Producer(name="生产者线程%d" % x)t.start()for x in range(3):t = Consumer(name="消费者线程%d" % x)t.start()if __name__ == '__main__':main()#做个笔记    注意代码缩进。。。。。。

# -*- coding:utf-8 -*-import time
import Queue
import threading# q = Queue.Queue(4)# for x in range(4):
#     q.put(x)
# print q.qsize()  队列大小
# print q.full()  队列是否满
#
# for x in range(4):
#     print q.get()#q.get(block=True) #默认阻塞# q.put(block=True)def set_value(q):index = 0while True:q.put(index)index += 1time.sleep(3)def get_value(q):while True:print q.get()def main():q = Queue.Queue()t1 = threading.Thread(target=set_value,args=[q])t2 = threading.Thread(target=get_value,args=[q])t1.start()t2.start()if __name__ == '__main__':main()