Condition实现精准的通知和唤醒线程

如何精准通知和唤醒线程?
通过重复新建Condition监视器,通过在资源类中进行一个if的判断,如果不等于numbername就 condition.await()否则的话就通过new出的监听器来唤醒另个一个线程.思路很简单,是基于上一篇文章.

package com.xnizhi;

import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

/**
 * @author LZP
 * @create 2020/7/8
 */
public class ConditionTest {
    public static void main(String[] args) {
        thisTset thisTset = new thisTset();
        new Thread(() -> {
            for (int i = 0; i < 10; i++) {
                thisTset.Test1();
            }
        }, "A").start();
        new Thread(() -> {
            for (int i = 0; i < 10; i++) {
                thisTset.Test2();
            }
        }, "B").start();
        new Thread(() -> {
            for (int i = 0; i < 10; i++) {
                thisTset.Test3();
            }
        }, "C").start();
    }
}

class thisTset {
    private Lock lock = new ReentrantLock();//新建锁
    private Condition condition1 = lock.newCondition();
    private Condition condition2 = lock.newCondition();
    private Condition condition3 = lock.newCondition();
    private int number = 1;
    public void Test1() {
        lock.lock();  //开启锁
        try {
            while (number != 1){
                condition1.await();
            }
            System.out.println(Thread.currentThread().getName() + "1在等待");
            number = 2;
            condition2.signal();
            System.out.println("condition2被唤醒");
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            lock.unlock();  //释放锁
        }
    }

    public void Test2() {
        lock.lock();  //开启锁
        try {
            while (number != 2){
                condition2.await();
            }
            System.out.println(Thread.currentThread().getName() + "2在等待");
            number = 3;
            condition3.signal();
            System.out.println("condition3被唤醒");
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            lock.unlock();  //释放锁
        }
    }

    public void Test3() {
        lock.lock();  //开启锁
        try {
            while (number != 3){
                condition3.await();
            }
            System.out.println(Thread.currentThread().getName() + "3在等待");
            number = 1;
            condition1.signal();
            System.out.println("condition3被唤醒");
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            lock.unlock();  //释放锁
        }
    }
}

在这里插入图片描述


版权声明:本文为qq_43712538原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。