文档章节

Lock&Condition

javahongxi
 javahongxi
发布于 2017/08/26 06:28
字数 220
阅读 9
收藏 0
package com.ixhong.base.thread;

import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class ThreeConditionCommunication {

   /**
    * @param args
*/
public static void main(String[] args) {
      
      final Business business = new Business();
      new Thread(
            new Runnable() {
               
               @Override
public void run() {
               
                  for(int i=1;i<=50;i++){
                     business.sub2(i);
                  }
                  
               }
            }
      ).start();
      
      new Thread(
            new Runnable() {
               
               @Override
public void run() {
               
                  for(int i=1;i<=50;i++){
                     business.sub3(i);
                  }
                  
               }
            }
      ).start();    
      
      for(int i=1;i<=50;i++){
         business.main(i);
      }
      
   }

   static class Business {
         Lock lock = new ReentrantLock();
         Condition condition1 = lock.newCondition();
         Condition condition2 = lock.newCondition();
         Condition condition3 = lock.newCondition();
        private int shouldSub = 1;
        public  void sub2(int i){
           lock.lock();
           try{
              while(shouldSub != 2){
                 try {
                  condition2.await();
               } catch (Exception e) {
                  // TODO Auto-generated catch block
e.printStackTrace();
               }
              }
               for(int j=1;j<=10;j++){
                  System.out.println("sub2 thread sequence of " + j + ",loop of " + i);
               }
              shouldSub = 3;
              condition3.signal();
           }finally{
              lock.unlock();
           }
        }

        public  void sub3(int i){
           lock.lock();
           try{
              while(shouldSub != 3){
                 try {
                  condition3.await();
               } catch (Exception e) {
                  // TODO Auto-generated catch block
e.printStackTrace();
               }
              }
               for(int j=1;j<=20;j++){
                  System.out.println("sub3 thread sequence of " + j + ",loop of " + i);
               }
              shouldSub = 1;
              condition1.signal();
           }finally{
              lock.unlock();
           }
        }         
        
        public  void main(int i){
           lock.lock();
           try{
             while(shouldSub != 1){
                  try {
                     condition1.await();
                  } catch (Exception e) {
                     // TODO Auto-generated catch block
e.printStackTrace();
                  }
               }
               for(int j=1;j<=100;j++){
                  System.out.println("main thread sequence of " + j + ",loop of " + i);
               }
               shouldSub = 2;
               condition2.signal();
        }finally{
           lock.unlock();
        }
     }
   
   }
}

© 著作权归作者所有

javahongxi
粉丝 168
博文 259
码字总数 779422
作品 0
朝阳
程序员
私信 提问
Java基础巩固笔记(8)-多线程之线程并发库

Contents java基础巩固笔记(5)-多线程之线程并发库 原子性操作类 线程池 Lock&Condition 同步工具 参考资料 本文主要概述包下的相关类和使用方法 Package java.util.concurrent 原子性操作类...

卟想苌亣
2017/12/04
0
0
java并发编程之wait¬ify VS lock&condition

jdk5之前线程同步可以用synchronized/wait/notify来进行控制,jdk5以后新添加了lock/condition。他们之间有什么联系与区别的?本文就用一个例子循序渐进的给大家展示一下: 首先来看一个有界...

若鱼1919
2018/07/06
0
0
java基础巩固笔记(5)-多线程之线程并发库

java基础巩固笔记(5)-多线程之线程并发库 标签: java [TOC] 本文主要概述包下的相关类和使用方法 Package java.util.concurrent 原子性操作类 包下的类: Package java.util.concurrent.atom...

brianway
2016/02/06
1K
0

没有更多内容

加载失败,请刷新页面

加载更多

没有更多内容

Spring Security 自定义登录认证(二)

一、前言 本篇文章将讲述Spring Security自定义登录认证校验用户名、密码,自定义密码加密方式,以及在前后端分离的情况下认证失败或成功处理返回json格式数据 温馨小提示:Spring Security...

郑清
18分钟前
1
0
php yield关键字以及协程的实现

php的yield是在php5.5版本就出来了,而在初级php界却很少有人提起,我就说说个人对php yield的理解 Iterator接口 在php中,除了数组,对象可以被foreach遍历之外,还有另外一种特殊对象,也就是继承...

冻结not
31分钟前
1
0
servlet请求和响应的过程

本文转载于:专业的前端网站➥servlet请求和响应的过程 1.加载 Servlet类被加载到Java虚拟机中,并且实例化。在这个过程中,web容器(例如tomcat)会调用Servlet类的公开无参构造函数,产生一...

前端老手
31分钟前
2
0
golang 1.13 errors 包来了,不用写“err 气功波”代码

引 这篇是对 errors 包 的姿势挖掘 气功波错误代码 从 http.Get()返回的错误 判断 syscall.ECONNREFUSED 错误.以前要对 go 标准库 error 结构有点熟悉,才能写出下面的代码 func CmdErr(err ...

guonaihong
34分钟前
23
0
喜玛拉雅已听书单

时间倒序排 书名 作者 状态 唐砖 孑与2 进行中 死灵之书(克苏鲁神话合集) 阿卜杜拉·阿尔哈萨德 进行中 赡养人类 刘慈欣 完结 赡养上帝 刘慈欣 完结 中国太阳 刘慈欣 完结 中国太阳 刘慈欣...

Alex_Java
36分钟前
5
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部