zoukankan      html  css  js  c++  java
  • Java-JUC(九):使用Lock替换synchronized,使用Condition的await,singal,singalall替换object的wait,notify,notifyall实现线程间的通信

    Condition:

    • condition接口描述了可能会与锁有关的条件变量。这些用法上与使用object.wait访问隐式监视器类似,但提供了更强大的功能。需要特别指出的是,单个lock可能与多个Condition对象关联。为了避免兼容性问题,Condition方法的名称与对应的objec版本中的不同。
    • 在condition对象中,与wait、notify、notifyall方法对应的分别是await、singal、signalAll
    • Condition实例实质上被绑定到一个锁上。要为特定Lock实例获得Condition实例,请使用其newCondition()方法。

    使用Lock替换Synchronized,使用Condition替换Ojbect实现线程间的通信

    例子如下:

    package com.dx.juc.test;
    
    import java.util.concurrent.locks.Condition;
    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReentrantLock;
    
    public class LockAndConditionTest {
        public static void main(String[] args) {
            Clerk clerk = new Clerk();
            Productor productor = new Productor(clerk);
            Consumer consumer = new Consumer(clerk);
    
            new Thread(productor, "Productor-A").start();
            new Thread(consumer, "Consumer-A").start();
    
            new Thread(productor, "Productor-B").start();
            new Thread(consumer, "Consumer-B").start();
        }
    }
    
    /**
     * 店员
     */
    class Clerk {
        private int product = 0;
        private Lock lock = new ReentrantLock();
        private Condition condition = lock.newCondition();
    
        /**
         * 进货
         */
        public void purchase() {
            lock.lock();
    
            try {
                while (product >= 1) {
                    System.out.println(Thread.currentThread().getName() + ":" + "产品已满。。。");
                    try {
                        condition.await();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
    
                System.out.println(Thread.currentThread().getName() + ":" + ++product);
                condition.signalAll();
            } finally {
                lock.unlock();
            }
        }
    
        /**
         * 卖货
         */
        public void sell() {
            lock.lock();
    
            try {
                while (product <= 0) {
                    System.out.println(Thread.currentThread().getName() + ":" + "产品缺貨。。。");
                    try {
                        condition.await();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
    
                System.out.println(Thread.currentThread().getName() + ":" + --product);
                condition.signalAll();
            } finally {
                lock.unlock();
            }
        }
    }
    
    /**
     * 生产者 不断的生产产品给店员
     */
    class Productor implements Runnable {
        private Clerk clerk;
    
        public Productor(Clerk clerk) {
            this.clerk = clerk;
        }
    
        public void run() {
            for (int i = 0; i < 2; i++) {
                clerk.purchase();
            }
        }
    }
    
    /**
     * 消费者 不断的从店员那里消费产品
     */
    class Consumer implements Runnable {
        private Clerk clerk;
    
        public Consumer(Clerk clerk) {
            this.clerk = clerk;
        }
    
        public void run() {
            for (int i = 0; i < 2; i++) {
                clerk.sell();
            }
        }
    }
  • 相关阅读:
    使用Oracle Wrap工具加密你的代码
    Oracle wrap 和 unwrap( 加密与解密) 说明
    oracle_base和oracle_home 的区别
    Oracle的SOME,ANY和ALL操作
    Oracle自主事务处理
    oracle读写文件--利用utl_file包对磁盘文件的读写操作
    Oracle中序列的使用
    INSTEAD OF触发器
    DBMS_LOB包的使用
    Oracle入门4-REF Cursor
  • 原文地址:https://www.cnblogs.com/yy3b2007com/p/8972263.html
Copyright © 2011-2022 走看看