Java学习者论坛

 找回密码
 立即注册

QQ登录

只需一步,快速开始

手机号码,快捷登录

恭喜Java学习者论坛(https://www.javaxxz.com)已经为数万Java学习者服务超过8年了!积累会员资料超过10000G+
成为本站VIP会员,下载本站10000G+会员资源,购买链接:点击进入购买VIP会员
JAVA高级面试进阶视频教程Java架构师系统进阶VIP课程

分布式高可用全栈开发微服务教程

Go语言视频零基础入门到精通

Java架构师3期(课件+源码)

Java开发全终端实战租房项目视频教程

SpringBoot2.X入门到高级使用教程

大数据培训第六期全套视频教程

深度学习(CNN RNN GAN)算法原理

Java亿级流量电商系统视频教程

互联网架构师视频教程

年薪50万Spark2.0从入门到精通

年薪50万!人工智能学习路线教程

年薪50万!大数据从入门到精通学习路线年薪50万!机器学习入门到精通视频教程
仿小米商城类app和小程序视频教程深度学习数据分析基础到实战最新黑马javaEE2.1就业课程从 0到JVM实战高手教程 MySQL入门到精通教程
查看: 295|回复: 0

[Java线程学习]wait与notify的使用

[复制链接]
  • TA的每日心情
    开心
    2021-3-12 23:18
  • 签到天数: 2 天

    [LV.1]初来乍到

    发表于 2014-10-28 23:56:50 | 显示全部楼层 |阅读模式
    我今天来解释下wai与与notify的用法了。
            其实也是非常简单的,就是个消费与生产的问题,当消费大于生产值的时候就使消费线程停止,等待生产线程的通知
    class Test
    {
      int value = 30;
      
      public synchronized int getValue()         
      {
       return value;
      }
      public Test()         
      {
       T t1 = new T("t1");
       T t2 = new T("t2");
       t1.start();
       t2.start();
      }
       
      


      public synchronized  void  increase()    //Test的生产方法
      {
       value++;
       if(value > 30)
        notify();
      }
      
      public synchronized  void  decrease()  //Test的消费方法
      {
       try
       {
        value -= 8;
        if(value <= 0)
         wait();
       }
       catch(Exception e)
       {
        e.printStackTrace();
       }
      }
       

      class T
       extends Thread
      {
       public void run()
       {
        while(true)
        {
         dos();
        }
       }
       
       
       public T(String n)
       {
        this.setName(n);
       }
       
       public synchronized void dos()
       {
        try
        {
         System.out.println(Thread.currentThread().getName() + "  " + value);
         if("t1".equals(Thread.currentThread().getName()))
         {
          increase();      //叫做t1的线程负责Test的生产
         }
         if("t2".equals(Thread.currentThread().getName()))
         {
          decrease();      //叫做t2的线程负责Test的消费
         }
         Thread.currentThread().sleep(200);
        }
        catch(Exception e)
        {
         e.printStackTrace();
        }
       }
      }
      
      public static void main(String argv[])
      {
       Test t1 = new Test();
       
      }
      
    }
    这里注意的是Test的类使用wai方法来阻止消费线程继续消费。  程序运行结果:
    C:java>java Test
    t1 30
    t2 31
    t1 23
    t2 24
    t1 16
    t2 17
    t1 9
    t2 10
    t1 2
    t2 3
    t1 -5
    t1 -4
    t1 -3
    t1 -2
    t1 -1
    t1 0
    t1 1
    t1 2
    t1 3
    t1 4
    t1 5
    t1 6
    t1 7
    t1 8
    t1 9
    t1 10
    t1 11
    t1 12
    t1 13
    t1 14
    t1 15
    t1 16
    t1 17
    t1 18
    t1 19
    t1 20
    t1 21
    t1 22
    t1 23
    t1 24
    t1 25
    t1 26
    t1 27
    t1 28
    t1 29
    t1 30
    t1 31
    t2 32
    t1 24
    t2 25
    t1 17
    t2 18
    t1 10
    t2 11
    t1 3
    t2 4
    t1 -4
    t1 -3
    t1 -2
    t1 -1
    t1 0
    t1 1
    t1 2
    t1 3
    t1 4
    t1 5
    t1 6
    t1 7
    t1 8
    t1 9
    t1 10
    t1 11 。。。。。。 C:java>

      
      
       
       

         
       

         
       
      
       

      










    源码下载:http://file.javaxxz.com/2014/10/28/235649718.zip
    回复

    使用道具 举报

    您需要登录后才可以回帖 登录 | 立即注册

    本版积分规则

    QQ|手机版|Java学习者论坛 ( 声明:本站资料整理自互联网,用于Java学习者交流学习使用,对资料版权不负任何法律责任,若有侵权请及时联系客服屏蔽删除 )

    GMT+8, 2025-2-26 02:32 , Processed in 0.295719 second(s), 36 queries .

    Powered by Discuz! X3.4

    © 2001-2017 Comsenz Inc.

    快速回复 返回顶部 返回列表