zoukankan      html  css  js  c++  java
  • 线程间通讯(交替打印ABC)

    package com.kaibing.thread;
    
    import java.util.concurrent.locks.Condition;
    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReentrantLock;
    
    public class ABCAlternate {
    
        public static void main(String[] args) {
            Alternate alternate = new Alternate();
    
            new Thread(new Runnable() {
                @Override
                public void run() {
                    for (int i=0;i<20;i++){
                        alternate.printA(i);
                    }
                }
            },"A").start();
            new Thread(new Runnable() {
                @Override
                public void run() {
                    for (int i=0;i<20;i++){
                        alternate.printB(i);
                    }
                }
            },"B").start();
            new Thread(new Runnable() {
                @Override
                public void run() {
                    for (int i=0;i<20;i++){
                        alternate.printC(i);
                    }
                }
            },"C").start();
        }
    
    }
    class Alternate{
    
        private int number = 1;
    
        private Lock lock = new ReentrantLock();//
    
        private Condition condition1 = lock.newCondition();
        private Condition condition2 = lock.newCondition();
        private Condition condition3 = lock.newCondition();
    
    
        public void printA(int totalLoop){
    
            lock.lock();//加锁
    
            try{
                if (number != 1){
                    condition1.await();
                }
                System.out.println(Thread.currentThread().getName() + " == 	A	" + "第" + totalLoop + "次循环");
    
                number = 2;
                condition2.signal();//唤醒2
            } catch (InterruptedException e) {
                e.printStackTrace();
            } finally {
                lock.unlock();//释放锁
            }
    
        }
    
        public void printB(int totalLoop){
    
            lock.lock();//加锁
    
            try{
                if (number != 2){
                    condition2.await();
                }
                System.out.println(Thread.currentThread().getName() + " == 	B	" + "第" + totalLoop + "次循环");
    
                number = 3;
                condition3.signal();//唤醒3
            } catch (InterruptedException e) {
                e.printStackTrace();
            } finally {
                lock.unlock();//释放锁
            }
    
        }
        public void printC(int totalLoop){
    
            lock.lock();//加锁
    
            try{
                if (number != 3){
                    condition3.await();
                }
                System.out.println(Thread.currentThread().getName() + " == 	C	" + "第" + totalLoop + "次循环");
    
                number = 1;
                condition1.signal();//唤醒1
            } catch (InterruptedException e) {
                e.printStackTrace();
            } finally {
                lock.unlock();//释放锁
            }
    
        }
    
    
    }
  • 相关阅读:
    Java设计模式(学习整理)---工厂模式
    Java Swing 使用总结(转载)
    Java-生成验证码图片(自定义内容,尺寸,路径)
    二维码(带有图片)的生成
    J2se中的声音---AudioPlayer
    文件的读取和写入(指定路径)
    ASP.NET:使用Flurl制作可复用的分页组件
    ASP.NET:Forms身份验证和基于Role的权限验证
    ASP.NET:MVC模板化机制
    ASP.NET:MVC中文件上传与地址变化处理
  • 原文地址:https://www.cnblogs.com/kaibing/p/9258336.html
Copyright © 2011-2022 走看看