#!/usr/bin/env python
#-*- coding:utf-8 -*-
import threading,random,time
VALUE = 1000
Lock = threading.Lock()
class Product(threading.Thread):
def run(self):
global VALUE
while True:
m = random.randint(100,500)
Lock.acquire()
VALUE += m
print('%s 生成了数字 %s ，当初数字大小为 %s ' %(threading.current_thread(),m,VALUE))
Lock.release()
time.sleep(0.5)
class Consumer(threading.Thread):
def run(self):
global VALUE
while True:
m = random.randint(200,600)
Lock.acquire()
if VALUE >= m:
VALUE -= m
print('%s 生产了数字 %s ，当初数字大小为 %s ' %(threading.current_thread(),m,VALUE))
else:
print('数字 %s 太小' %VALUE)
Lock.release()
time.sleep(0.5)
def main():
for x in range(3):
t = Consumer(name='消费者线程%d' %(x))
t.start()
for x in range(5):
t = Product(name='生产者线程%d' %(x))
t.start()
if __name__ == '__main__':
main()
搞代码网（gaodaima.com）提供的所有资源部分来自互联网，如果有侵犯您的版权或其他权益，请说明详细缘由并提供版权或权益证明然后发送到邮箱[email protected]，我们会在看到邮件的第一时间内为您处理，或直接联系QQ：872152909。本网站采用BY-NC-SA协议进行授权
转载请注明原文链接：python-生产消费案例1
转载请注明原文链接：python-生产消费案例1
