zoukankan      html  css  js  c++  java
  • java Conditions

    //Listing 7-2. Achieving Synchronization in Terms of Locks and Conditions
    import java.util.concurrent.locks.Condition;
    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReentrantLock;
    
    public class A {
        public static void main(String[] args) {
            Shared s = new Shared();
            new Producer(s).start();
            new Consumer(s).start();
        }
    }
    
    class Shared {
        private char c;
        private volatile boolean available;
        private final Lock lock;
        private final Condition condition;
    
        Shared() {
            available = false;
            lock = new ReentrantLock();
            condition = lock.newCondition();
        }
    
        Lock getLock() {
            return lock;
        }
    
        char getSharedChar() {
            lock.lock();
            try {
                while (!available)
                    try {
                        condition.await();
                    } catch (InterruptedException ie) {
                        ie.printStackTrace();
                    }
                available = false;
                condition.signal();
            } finally {
                lock.unlock();
                return c;
            }
        }
    
        void setSharedChar(char c) {
            lock.lock();
            try {
                while (available)
                    try {
                        condition.await();
                    } catch (InterruptedException ie) {
                        ie.printStackTrace();
                    }
                this.c = c;
                available = true;
                condition.signal();
            } finally {
                lock.unlock();
            }
        }
    }
    
    class Producer extends Thread {
        private final Lock l;
        private final Shared s;
    
        Producer(Shared s) {
            this.s = s;
            l = s.getLock();
        }
    
        @Override
        public void run() {
            for (char ch = 'A'; ch <= 'Z'; ch++) {
                l.lock();
                s.setSharedChar(ch);
                System.out.println(ch + " produced by producer.");
                l.unlock();
            }
        }
    }
    
    class Consumer extends Thread {
        private final Lock l;
        private final Shared s;
    
        Consumer(Shared s) {
            this.s = s;
            l = s.getLock();
        }
    
        @Override
        public void run() {
            char ch;
            do {
                l.lock();
                ch = s.getSharedChar();
                System.out.println(ch + " consumed by consumer.");
                l.unlock();
            } while (ch != 'Z');
        }
    }
  • 相关阅读:
    针对大数据量 高并发量网站的解决方案
    session cookie 在用户登录中的使用
    彻底弄懂HTTP缓存机制及原理
    cookie 和session 的区别详解
    常见的浏览器兼容性问题
    内容分发网络(CDN)
    表现与数据分离、Web语义化
    关于bootstrap样式重写,无法覆盖的问题
    判断一个字符串中出现次数最多的字符
    [译]SQL Passion Week 10: 计划缓存
  • 原文地址:https://www.cnblogs.com/rojas/p/5381316.html
Copyright © 2011-2022 走看看