多线程之生产者和消费者模式

思路：

需要定义一个全局变量，供生产者和消费者使用

1、对于生产者来说：x>0 wait(print) ，否则x+1(使用for循环)

2、对于消费者来说：x==0 wait(print)，否则x-1（使用for循环）

3、生产者和消费者分别是一个class

__author__ = 'anna'
# coding: utf-8

import threading
x = 0  # 定义变量x


class Producer(threading.Thread):

    def __init__(self, name):
        threading.Thread.__init__(self)
        self.name = name

    def run(self):
        # global语句可以声明一个或多个变量为全局变量，该声明仅仅在当前代码块中有效，除此之外，没有办法访问全局变量
        global x
        threadLock.acquire()
        if x > 0:
            print("我已经有东西了，再等等呗！")
        else:
            for i in range(6):
                x += 1
                print("%s正在生产，第%d个" % (self.name, x))
        threadLock.release()


class Consumer(threading.Thread):

    def __init__(self, name):
        threading.Thread.__init__(self)
        self.name = name

    def run(self):
        global x
        threadLock.acquire()
        if x == 0:
            print("我没有东西了，我需要生产！")
        else:
            for i in range(5):
                x -= 1
                print("%s正在消费，第%d个" % (self.name, x))
        threadLock.release()

threadLock = threading.Lock()
p1 = Producer('我的生产者线程')
p1.start()
p1.join()  # 需要加上join方法，因为只有先生产才能消费，加上join方法不会导致错乱

c1 = Consumer('我的消费者线程')
c1.start()
c1.join()