以下讲解Lock线程同步通信,也是比synchronized强大的一个功能点

先看一个常规的案例:

用户类

public class Person {
    public void eat(){
        for(int i=0;i<3;i++){
            System.out.println("eat...");
        }
    }

    public void drink(){
        for(int i=0;i<3;i++){
            System.out.println("drink...");
        }
    }

    public void play(){
        for(int i=0;i<3;i++){
            System.out.println("play...");
        }
    }
}
public class LockConditionTest {
    public static void main(String[] args) {
        final Person person = new Person();
        new Thread(
                new Runnable() {
                    @Override
                    public void run() {
                        for(int i=0;i<5;i++){
                            person.eat();
                        }
                    }
                }
                )
        .start();

        new Thread(
                new Runnable() {
                    @Override
                    public void run() {
                        for(int i=0;i<5;i++){
                            person.drink();
                        }
                    }
                }
                )
        .start();

        for(int i=0;i<10;i++){
            person.play();
        }
    }
}

结果输出:

eat...
eat...
play...
play...
play...
play...
play...
play...
play...
drink...
drink...
play...
play...
play...
play...

以上案例为传统线程调用,打印的结果也是有cpu随机调度输出

现在的需求是:person 吃喝玩方法要有顺序性调用,阻止cpu随机调度输出

参考以下案例(加入Lock实现同步通信):

public class Person {

    Lock lock = new ReentrantLock();
    Condition condition1 = lock.newCondition();
    Condition condition2 = lock.newCondition();
    Condition condition3 = lock.newCondition();
    private int shouldSub = 1;

    public void eat(){
        lock.lock();
        try{
            while(shouldSub!=1){      //是1的时候执行  不是1的时候等待
                try {
                    condition1.await();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            for(int i=0;i<3;i++){
                System.out.println("eat...");
            }
            shouldSub=2;
            condition2.signal();    // 1 执行完之后 通知2执行
         }finally{
             System.out.println("=======================");
             lock.unlock();
         }
    }

    public void drink(){
        lock.lock();
        try{
            while(shouldSub!=2){ //是2的时候执行  不是2的时候等待
                try {
                    condition2.await();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            for(int i=0;i<3;i++){
                System.out.println("drink...");
            }
            shouldSub = 3;
            condition3.signal();// 2 执行完之后 通知3执行
         }finally{
             System.out.println("=======================");
             lock.unlock();
         }
    }

    public void play(){
        lock.lock();
        try{
            while(shouldSub!=3){    //是3的时候执行  不是3的时候等待
                try {
                    condition3.await();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            for(int i=0;i<3;i++){
                System.out.println("play...");
            }
            shouldSub = 1;
            condition1.signal();// 3 执行完之后 通知1执行
        }finally{
            System.out.println("=======================");
             lock.unlock();
         }
    }
}
public class LockConditionTest {
    public static void main(String[] args) {
        final Person person = new Person();
        new Thread(
                new Runnable() {
                    @Override
                    public void run() {
                        for(int i=0;i<5;i++){
                            person.eat();
                        }
                    }
                }
                )
        .start();

        new Thread(
                new Runnable() {
                    @Override
                    public void run() {
                        for(int i=0;i<5;i++){
                            person.drink();
                        }
                    }
                }
                )
        .start();

        for(int i=0;i<5;i++){
            person.play();
        }
    }
}

结果输出:

eat...
eat...
eat...
=======================
drink...
drink...
drink...
=======================
play...
play...
play...
=======================
eat...
eat...
eat...
=======================
drink...
drink...
drink...
=======================
play...
play...
play...
=======================
eat...
eat...
eat...
=======================
drink...
drink...
drink...
=======================
play...
play...
play...
=======================

最新文章

  1. 【BZOJ】4001: [TJOI2015]概率论
  2. openssl之rsa
  3. Winform窗体事件发生顺序
  4. win10系统更新补丁时进度条一直卡在0%不动的解决方案
  5. mapreduce 输入输出类型
  6. python3_RoboBrowser_test
  7. 关于HTTP协议的学习
  8. String inputStream file转化
  9. HandlerThread 类的学习(转载)
  10. IQueryable接口与IEnumberable区别
  11. ADS的默认连接分析及编译器产生符号解惑
  12. linux进程间通信之共享内存篇
  13. 前端HR告诉你—如何面试Web前端开发
  14. 通过Servlet实现汉字验证码
  15. HDU1411 欧拉四面体
  16. Halcon一日一练:创建三通道图像
  17. 视音频编解码学习工程:JPEG分析器
  18. 实践练习_使用HTML标签制作一个注册界面03
  19. python后端从数据库请求数据给到前端的具体实现
  20. Binary Tree HDU - 5573 (思维)

热门文章

  1. Angular.js 使用$http的response得到的phone属性为undefined
  2. win32 socket 编程(六)——UDP
  3. mysql的sql语句优化方法面试题总结
  4. Linux压缩、解压
  5. JQ的简单使用(基础)——————JQ
  6. vue 中使用class(样式)
  7. HTML拖放元素
  8. java操作mongodb工具类
  9. Elasticsearch Java Low Level REST Client(嗅探器)
  10. C6678芯片