Java多线Condition条件变量正确使用方法详解

public synchronized void doSomething(){
    //执行方法
    if(条件不满足){
        //线程等待
        Object.wait();
    }
    //条件此时满足，对象被唤醒，继续执行方法
}

//定义一个锁
public static final Lock reentrantLock = new ReentrantLock();
//定义属于这个锁的条件变量
public static final Condition condition = reentrantLock.newCondition();

void await() throws InterruptedException;

boolean await(long time, TimeUnit unit)

condition.signal();

condition.signalAll();

public class GlobalSymbol {
    /**
     * 定义全局标志位
     */
    public static AtomicBoolean globalFlag = new AtomicBoolean(false);
}

public class Main {
    //定义一个锁
    public static final Lock reentrantLock = new ReentrantLock();
    //定义属于这个锁的条件变量
    public static final Condition condition = reentrantLock.newCondition();
    public static void main(String[] args) {
        //先启动一下线程
        Thread thread = new Thread(new OtherThread());
        thread.start();
        //先加锁
        reentrantLock.lock();
        try {
            System.out.println("线程加锁成功，正在执行相关代码");
            while (!GlobalSymbol.globalFlag.get()){
                System.out.println("现在条件还不满足，先等待");
                condition.await();
            }
            System.out.println("线程被唤醒，执行后续代码");
        }
        catch (Exception e){
            System.out.println("加锁解锁逻辑出现异常");
        }
        finally {
            //在finally中释放锁
            reentrantLock.unlock();
        }
        System.out.println("程序结束");
    }
}

public class OtherThread implements Runnable{
    @Override
    public void run() {
        try {
            for (int i = 10; i > 0; i--){
                System.out.println("标志位将在" + i + "秒后置为true");
                TimeUnit.SECONDS.sleep(1);
            }
            GlobalSymbol.globalFlag.set(true);
            //对被阻塞的线程进行唤醒（必须获得对应的锁后，才能执行唤醒的操作）
            Main.reentrantLock.lock();
            Main.condition.signalAll();
            Main.reentrantLock.unlock();
        }
        catch (Exception e){
            System.out.println("线程执行失败");
        }
    }
}