Java多线程阻塞与唤醒问题实例-蒲公英云

Java多线程阻塞与唤醒问题实例

原创男娘i 2024-09-19 04:21 181阅读 0赞

在Java多线程中，阻塞与唤醒是两种常见的同步机制。下面通过一个简单的生产者消费者（Producer-Consumer）模型来展示。

生产者（ProducerThread）：

class ProducerThread extends Thread {
 private int count = 0;
 public ProducerThread(String name) {
     super(name);
 }
 public void produce() {
     try {
         while (count <= 10) { // 每生产10个产品就暂停
             System.out.println("Producer produced: " + count++);
             // 延迟时间，模拟真实情况中的等待
             Thread.sleep(500);
             // 让消费者线程有机会处理
             synchronized (consumerLock) {
                 consumerLock.notify();
             }
         } // 暂停循环
     } catch (InterruptedException e) {
         e.printStackTrace();
     }
 }
}

消费者（ConsumerThread）：

class ConsumerThread extends Thread {
 private int count = 0;
 public ConsumerThread(String name) {
     super(name);
 }
 public void consume() {
     try {
         while (count <= 10) { // 当产品数量少于10时消费
             System.out.println("Consumer consumed: " + count++);
             // 让生产者线程有机会处理
             synchronized (producerLock) {
                 producerLock.notify();
             }
         } // 消费循环
     } catch (InterruptedException e) {
         e.printStackTrace();
     }
 }
}