线程间的通信

喜欢ヅ旅行 2022-01-29 10:34 340阅读 0赞

典型例子就是生产者-消费者模式，仓库为空时，消费者无法从仓库调动产品，只能wait，直到仓库有产品时被notify；仓库满了时，生产者则暂时停止生产（wait），直到仓库有空被notify。
仓库售货员类：

  1. package com.sy.iodemo;
  3. public class Clerk {
  4.     private int product =0;
  5.     public synchronized void addProduct(){
  6.         if(product >= 10){
  7.             try{
  8.                 wait();
  9.             }catch(InterruptedException e){
  10.                 e.printStackTrace();
  11.             }
  12.         }else{
  13.             product++;
  14.             System.out.println("生产者生产了第"+product+"个产品");
  15.             notifyAll();
  16.         }
  17.     }
  18.     public synchronized void getProduct(){
  19.         if(product <=0){
  20.             try{
  21.                 wait();
  22.             }catch(InterruptedException e){
  23.                 e.printStackTrace();
  24.             }
  25.         }else{
  26.             System.out.println("消费者取走了第"+product+"个产品");
  27.             product--;
  28.             notifyAll();
  29.         }
  30.     }
  31. }

生产者类：

  1. package com.sy.iodemo;
  3. public class Productor implements Runnable{
  4.     Clerk clerk;
  5.     public Productor(Clerk clerk){
  6.         this.clerk = clerk;
  7.     }
  8.     public void run(){
  9.         while(true){
  10.             try{
  11.                 Thread.sleep(2000);
  12.             }catch(InterruptedException e){
  13.                 e.printStackTrace();
  14.             }
  15.             clerk.addProduct();
  16.         }
  17.     }
  19. }

消费者类：

  1. package com.sy.iodemo;
  3. public class Consumer implements Runnable{
  4.     Clerk clerk;
  5.     public Consumer(Clerk clerk){
  6.         this.clerk = clerk;
  7.     }
  8.     public void run(){
  9.         while(true){
  10.             try{
  11.                 Thread.sleep(2000);
  12.             }catch(InterruptedException e){
  13.                 e.printStackTrace();
  14.             }
  15.             clerk.getProduct();
  16.         }
  17.     }
  19. }

结果（部分）：

  1. 生产者生产了第1个产品
  2. 生产者生产了第2个产品
  3. 消费者取走了第2个产品
  4. 生产者生产了第2个产品
  5. 消费者取走了第2个产品
  6. 生产者生产了第2个产品
  7. 消费者取走了第2个产品
  8. 生产者生产了第2个产品
  9. 消费者取走了第2个产品

发表评论

表情：
评论列表 （有 0 条评论，340人围观）

还没有评论，来说两句吧...

相关阅读

    相关 线程间的通信

    1、什么是多线程之间通信 多个线程在处理同一个资源，并且任务不同时，需要线程通信来帮助解决线程之间对同一个变量的使用或操作。 于是我们引出了等待唤醒机制：

    梦里梦外;梦里梦外;/ 0 赞/ 78 阅读

    相关 线程间通信

    为什么需要线程通讯 线程是操作系统调度的最小单位，有自己的栈空间，可以按照既定的代码逐步的执行，但是如果每个线程间都孤立的运行，那就会造资源浪费。所以在现实中，我们需要这

    心已赠人心已赠人/ 0 赞/ 360 阅读

    相关 线程间的通信

      https://www.cnblogs.com/hapjin/p/5492619.html 通常可用把并行程序理解为一组相互独立的、能够发关和接收消息的组件，这也称为角

    朱雀朱雀/ 0 赞/ 210 阅读

    相关 线程间通信

    线程和线程之间不是独立的个体，它们彼此之间可以互相通信和协作。 线程通信就是在线程之间传递信息，保证他们能够协同工作。在线程间进行通信后，系统之间的交互性会更强大，在大大提高

    Myth丶恋晨Myth丶恋晨/ 0 赞/ 368 阅读

    相关 线程间通信

    一、引言 线程与线程之间不是相互独立的存在，它们彼此之间需要相互通信和协作。最典型的例子就是生产者-消费者问题。下面首先介绍 wait/notify 机制，并对实现该机制

    墨蓝墨蓝/ 0 赞/ 398 阅读

    相关 线程间通信

    注意： 必须在同步方法中使用wait和notify方法，因为执行wait和notify的前提条件是必须持有同步方法（或块）的monitor的所有权，否则将会抛出异常

    女爷i女爷i/ 0 赞/ 493 阅读

    相关 线程间的通信

    典型例子就是生产者-消费者模式，仓库为空时，消费者无法从仓库调动产品，只能wait，直到仓库有产品时被notify；仓库满了时，生产者则暂时停止生产（wait），直到仓库有空被

    喜欢ヅ旅行喜欢ヅ旅行/ 0 赞/ 341 阅读