kotlin生产者消费者

Kotlin 中的生产者-消费者模型（Producer-Consumer Pattern）是一种经典的设计模式，用于解决线程安全的问题，尤其是在并发环境中处理数据流。它将数据生产者和消费者区分开，避免了对共享资源的直接访问，从而减少了竞态条件。

1. 生产者（Producer）：负责生成数据并将其放入一个共享的数据结构，如 `BlockingQueue` 或 `ArrayDeque` 中。生产者通常运行在一个独立的线程中，不断产生数据并添加到队列中。

2. 消费者（Consumer）：从共享数据结构中取出数据进行处理。消费者同样运行在一个独立的线程中，循环地从队列中读取数据并消费它。

3. 互斥锁（Mutex）或信号量（Semaphore）：为了保证数据结构的安全，生产者和消费者之间可能需要同步。通常使用 `ReentrantLock` 或 `Semaphore` 来控制对数据结构的访问权限，防止多个线程同时修改。

4. 关键代码部分：

   val queue = ArrayDeque<Int>()
   val producerLock = ReentrantLock()
   val consumerLock = ReentrantLock()

   // 生产者线程
   fun producer() {
       while (true) {
           with(producerLock) { // 获取生产者锁
               val data = generateData()
               queue.add(data)
               if (queue.size > MAX_SIZE) {
                   // 队列满，等待消费者处理
                   consumerLock.lock()
                   consumerLock.unlock()
               }
           }
       }
   }

   // 消费者线程
   fun consumer() {
       while (true) {
           with(consumerLock) { // 获取消费者锁
               if (queue.isEmpty()) {
                   // 队列空，生产者可能正在生成数据，等待
                   producerLock.lock()
                   producerLock.unlock()
               } else {
                   processData(queue.poll()) // 处理数据
               }
           }
       }
   }