多线程Lock的使用案例

分手后的思念是犯贱 2021-11-16 15:32 233阅读 0赞

### 一、使用Lock交替打印，效果如下 ###

![20190728213253724.gif][]

### 二、案例代码  ###

package com.zhq;
    
    import java.util.concurrent.locks.Condition;
    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReentrantLock;
    
    /**
     * 共享资源
     */
    class Res {
        public String name;
        public String sex;
        public Boolean flag=false;
        public Lock lock = new ReentrantLock();
        public Condition condition = lock.newCondition();
    }
    
    class InputThread extends Thread {
    
        public Res res;
    
        public InputThread(Res res) {
            this.res = res;
        }
    
        @Override
        public void run() {
            int count = 0;
            while (true) {
                try {
                    res.lock.lock();
                    if(res.flag){
                        try {
                            res.condition.await();
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                    if (count == 0) {
                        res.name = "小红";
                        res.sex = "女";
                    } else {
                        res.name = "小明";
                        res.sex = "男";
                    }
                    count = (count + 1) % 2;
                    res.flag=true;
                    res.condition.signal();
                } catch (Exception e) {
                    e.printStackTrace();
                } finally {
                    res.lock.unlock();
                }
            }
        }
    
    }
    
    class OutPutThread extends Thread {
    
        public Res res;
    
        public OutPutThread(Res res) {
            this.res = res;
        }
    
        @Override
        public void run() {
            int count = 0;
            while (true) {
                try {
                    res.lock.lock();
                    if(!res.flag){
                        res.condition.await();
                    }
                    System.out.println(res.name + res.sex);
                    res.flag=false;
                    res.condition.signal();
                } catch (Exception e) {
                    e.printStackTrace();
                } finally {
                    res.lock.unlock();
                }
            }
        }
    
    }
    
    /**
     * @program: ThreadDemo
     * @description:
     * @author: hq.zheng
     * @create: 2019-07-28 19:34
     */
    public class ReadAndWrite {
        public static void main(String[] args) {
            Res res = new Res();
            InputThread inputThread = new InputThread(res);
            OutPutThread outPutThread = new OutPutThread(res);
            inputThread.start();
            outPutThread.start();
        }
    }

[20190728213253724.gif]: /images/20211116/92dbc660537b4c52a6f1eca5c9e29683.png