JUC中的线程通信 Condition

Posted 2022-12-15 XeonYu

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了JUC中的线程通信 Condition相关的知识，希望对你有一定的参考价值。

上一篇文章我们简单用了下ReentrantLock。
我们知道，用synchronized的时候，我们可以通过Object类中的wait和notify来实现线程间的通信。但是wait和notify只能在synchronized中使用，那使用Lock时如何实现线程通信呢？

Condition

Condition是一个接口，他就是替代Object中的wait和notify方法来解决使用Lock时线程间的通信问题。

Condition要比Object中的wait和notify更加灵活一些，且能实现更加复杂的业务。

我们先来简单用一用Condition

有一下代码：

class MyNumber 
    private final ReentrantLock lock = new ReentrantLock();


    /*条件*/
    private final Condition condition = lock.newCondition();


    /*默认值为0*/
    private int number = 0;


    /*加操作*/
    public void add() 
        lock.lock();
        try 
            String name = Thread.currentThread().getName();

            while (number == 1) 
                /*当值为不为0时  等待其他线程将值变为变为0*/
                condition.await();
            

            /*值为0时  加一*/
            number++;
            System.out.println(name + "加一:" + number);
            /*通知其他个线程可以做减一操作了*/
            condition.signal();

         catch (Exception e) 
            e.printStackTrace();
         finally 
            if (lock.isHeldByCurrentThread()) 
                lock.unlock();
            

        
    


    public void reduce() 
        lock.lock();
        String name = Thread.currentThread().getName();

        try 
            /*值为0时  等待*/
            while (number == 0) 
                condition.await();
            

            /*不为0时  减一*/
            number--;
            System.out.println(name + "减一:" + number);

            /*通知其他线程可以做加一操作了*/
            condition.signal();
         catch (Exception e) 
            e.printStackTrace();
         finally 

            if (lock.isHeldByCurrentThread()) 
                lock.unlock();

这个Number类有两个方法，加一和减一。
main方法如下：

    public static void main(String[] args) 

        MyNumber number = new MyNumber();

        new Thread(() -> 

            for (int i = 0; i < 5; i++) 
                number.add();
            

        , "线程1").start();
        new Thread(() -> 

            for (int i = 0; i < 5; i++) 
                number.reduce();
            

        , "线程2").start();

运行一下：

可以看到，符合预期，线程之间的通信是没有问题的。

再加2个线程试一下：

    public static void main(String[] args) 

        MyNumber number = new MyNumber();

        new Thread(() -> 
            for (int i = 0; i < 5; i++) 
                number.add();
            
        , "线程1").start();
        new Thread(() -> 
            for (int i = 0; i < 5; i++) 
                number.reduce();
            
        , "线程2").start();
        new Thread(() -> 
            for (int i = 0; i < 5; i++) 
                number.add();
            
        , "线程3").start();
        new Thread(() -> 
            for (int i = 0; i < 5; i++) 
                number.reduce();
            
        , "线程4").start();