condition()函数的定义和用法示例

condition()是Python中的一个内建函数，用于创建一个Condition（条件变量）对象。Condition对象用于线程同步，在多个线程之间进行通信和协调。它提供了wait()、notify()和notifyAll()等方法，可以在不同线程之间实现等待、通知和唤醒操作。

condition()函数的定义如下：

class threading.Condition([lock])：创建一个Condition对象。lock参数可选，用于指定Condition对象的锁，默认为RLock对象。

在使用condition()函数前，需要先导入threading模块：

import threading

下面我们来看一个使用condition()函数的示例：

示例1：生产者-消费者模型

'''

import threading

# 创建Condition对象

con = threading.Condition()

# 定义商品和库存

product = None

stock = 0

# 生产者函数

def producer():

    global product, stock

    while True:

        # 加锁

        con.acquire()

        # 如果库存不为空，则等待

        if stock != 0:

            con.wait()

        # 生产商品

        product = "商品"

        stock += 1

        print("生产者生产了1个商品，库存为：%d" % stock)

        # 唤醒所有的消费者线程

        con.notifyAll()

        # 释放锁

        con.release()

# 消费者函数

def consumer():

    global product, stock

    while True:

        # 加锁

        con.acquire()

        # 如果库存为空，则等待

        if stock == 0:

            con.wait()

        # 消费商品

        product = None

        stock -= 1

        print("消费者消费了1个商品，库存为：%d" % stock)

        # 唤醒所有的生产者线程

        con.notifyAll()

        # 释放锁

        con.release()

# 创建2个生产者线程和3个消费者线程

for i in range(2):

    threading.Thread(target=producer).start()

for i in range(3):

    threading.Thread(target=consumer).start()

'''

上述示例演示了一个生产者-消费者模型的实现。生产者线程负责生产商品，消费者线程负责消费商品，使用Condition对象实现线程之间的等待和唤醒。

在示例中，首先创建一个Condition对象con。定义商品和库存两个全局变量，分别用于表示当前商品和库存数量。然后定义了生产者函数producer()和消费者函数consumer()。

生产者函数中，通过acquire()方法获取锁，判断库存是否为空，若不为空，则调用wait()方法进入等待状态。当库存为空时，生产商品、增加库存，并打印相关信息。然后调用notifyAll()方法唤醒所有的消费者线程，最后释放锁。

消费者函数中，与生产者函数类似，通过acquire()方法获取锁，判断库存是否为空，若为空，则调用wait()方法进入等待状态。当库存不为空时，消费商品、减少库存，并打印相关信息。然后调用notifyAll()方法唤醒所有的生产者线程，最后释放锁。

最后，通过创建2个生产者线程和3个消费者线程来模拟生产者-消费者模型。