栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

使用Lock实现线程的顺序执行(精准唤醒)

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

使用Lock实现线程的顺序执行(精准唤醒)



package com.learn;


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

public class Thread_Execute_Order {


   public static void main(String[] args) {

      Resource resource = new Resource();

      new Thread(() -> {
         try {
            //很重要,让其它依赖线程先执行wait方法。可以自己去掉试一下
            Thread.sleep(100);
         } catch (Exception e) {
            e.printStackTrace();
         }
         for(int i=0;i <5 ;i++){
            resource.method1();
         }
      },"ThreadA").start();

      new Thread(() -> {
         for(int i=0;i <5 ;i++){
            resource.method2();
         }
      },"ThreadB").start();

      new Thread(() -> {
         for(int i=0;i <5 ;i++){
            resource.method3();
      }},"ThreadC").start();



   }


}

class Resource{

   private Lock lock = new ReentrantLock();
   private Condition condition1 = lock.newCondition();
   private Condition condition2 = lock.newCondition();
   private Condition condition3 = lock.newCondition();

   private boolean methodBeginFlag = false;

   public void method1(){
      lock.lock();
      try {
         if(!methodBeginFlag ){
            //无条件限制性method1
            methodBeginFlag = true ;
         }else{
            condition1.await();
         }
         System.out.println("------------------->执行method1");
         Thread.sleep(1*1000);
         condition2.signal();
      } catch (Exception e) {
         e.printStackTrace();
      } finally {
         lock.unlock();
      }

   }

   public void method2(){
      lock.lock();
      try {
         condition2.await();
         System.out.println("------------------->执行method2");
            Thread.sleep(1*1000);
         condition3.signal();

      } catch (Exception e) {
         e.printStackTrace();
      } finally {
         lock.unlock();
      }
   }


   public void method3(){
      lock.lock();
      try {
         condition3.await();
         System.out.println("------------------->执行method3");
         Thread.sleep(1*1000);
         condition1.signal();
      } catch (Exception e) {
         e.printStackTrace();
      } finally {
         lock.unlock();
      }
   }

}

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/630843.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号