Java多线程同步工具类：Lock和Condition实例-蒲公英云

Java多线程同步工具类：Lock和Condition实例

在Java中，我们通常使用java.util.concurrent.locks.Lock接口来实现线程的同步。而java.util.concurrent.locks.Condition接口则用于实现线程间的通信。

以下是一个简单的例子，展示了如何创建Lock和Condition实例：

import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock; // 这里使用了可重入锁
import java.util.concurrent.locks.Condition;
public class MultiThreadSync {
    private Lock lock = new ReentrantLock(); // 创建锁
    private Condition condition = lock.newCondition(); // 创建条件
    public void printWhenReady() throws InterruptedException {
        lock.lock(); // 获取锁
        try {
            if (!condition.await(5, TimeUnit.SECONDS))) { // 如果5秒后没有满足条件，则抛出InterruptedException
                System.out.println("Ready after 5 seconds");
                }
            else {
                System.out.println("Ready when condition matched");
            }
        } finally {
            lock.unlock(); // 释放锁
        }
    }
    public static void main(String[] args) throws InterruptedException {
        MultiThreadSync sync = new MultiThreadSync();
        Thread producer = new Thread(() -> {
            try {
                for (int i = 0; i < 10; i++) {
                    System.out.println("Produced: " + i);
                    if (i == 5) { // 当生产到第五个元素时，通知消费者
                        sync.condition.signalAll(); // 使用signalAll()方法一次性唤醒所有等待的线程
                        }
                    Thread.sleep(100); // 模拟耗时操作
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        })});
        Thread consumer = new Thread(() -> {
            try {
                sync.printWhenReady(); // 当条件匹配时，打印"Ready when condition matched"
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("Consumer thread exiting...");
        })});
        producer.start(); // 启动生产者线程
        consumer.start(); // 启动消费者线程
        // 主程序等待所有线程执行完毕
        while (!producer.isDone() || !consumer.isDone()) {
            try {
                Thread.sleep(1000); // 模拟程序繁忙，减少主线程的占用
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}