Java线程之1.4版多生产多消费者示例（三）

心已赠人 2022-08-21 09:48 8阅读 0赞

## 多生产者，多消费者 ##

从单生产者单消费者示例进化而来

注意两个变化的地方：

*  为判断标记任务循环体的if—->while
 *  为避免死锁唤醒notify–>notifyAll

--------------------

1.  分析下（if+notifty）的安全隐患
    
     *  tp0先开锁获取CPU执行权 生产：1 然后flag=true, 唤醒进程缓冲池（），退出
     *  然后如果tp0,tp1再获得CPU执行资格，但是判断flag=true，进入缓冲池（tp0,tp1）
     *  然后tc0获取CPU执行权，消费：1 然后flag=false，唤醒缓冲池（tp0,tp1），退出，假设唤醒的tp1
     *  然后假如tc0,tc1想获取执行资格，判断flag = false，进入缓冲池（tp0，tc0，tc1）
     *  **此时已经唤醒的tp1并不会再去判断flag标识，继续向下执行，那么就出现了多生产无消费的情况**
    
    同理，1生产多消费的情况也可能发生  
    ![这里写图片描述][20160426165941295]
2.  如果是按照单线程（while+notify）来
    
     *  假如tp0先开锁获取CPU执行权 生产：1 然后flag=true, 唤醒进程缓冲池（），退出
     *  然后如果tp0,tp1再获得CPU执行资格，但是判断flag=true，进入缓冲池（tp0,tp1）
     *  然后tc0获取CPU执行权，消费：1 然后flag=false，唤醒缓冲池（tp0,tp1），退出，假设唤醒的tp1
     *  然后假如tc0,tc1想获取执行资格，判断flag = false，进入缓冲池（tp0，tc0，tc1）
     *  然后假如tp1执行，生产：2 同样flag=true ，
     *  **假如唤醒缓冲池中的是tp0而不是消费者tc0或者tc1，那么tp0和tp1判断后也会wait,这样最后4个进程都没有notify来唤醒，进入死锁**

### 将if（）改为while后可以让进程在wait后醒来再次判断flag ###

### notifyAll可以避免出现死锁，但是会造成效率低下 ###

\*/

class Resource { 
        String name;
        private int count = 1;
        String id ;
        private boolean flag = false;//初始默认没有产品
    
        public synchronized void producer(String name)
        {
            while(flag)
                try{wait();} catch (InterruptedException ex){}
            this.name = name;
            id = name + count++;
            System.out.println(Thread.currentThread().getName()+"--->生产："+id);
            flag = true;
            notifyAll();
        }
        public synchronized void consumer()
        {
            while(!flag)
                try{wait();} catch (InterruptedException ex){}
            System.out.println(Thread.currentThread().getName()+"--------->消费"+id);
            flag = false;
            notifyAll();
        }
    
    }
    class Producer implements Runnable { 
        Resource r;
        Producer(Resource r)
        {
            this.r = r;
        }
        public void run()
        {
            while(true)
            {
                r.producer("包子");
            }
        }
    }
    class Consumer implements Runnable { 
        Resource r;
        Consumer(Resource r)
        {
            this.r = r;
        }
        public void run()
        {
            while (true)
            {
                r.consumer();
            }
        }
    }
    class ThreadPC2 { 
        public static void main(String[] args) 
        {
            //创建资源
            Resource r = new Resource();
            //创建线程任务
            Producer p0 = new Producer(r);
            Producer p1 = new Producer(r);
            Consumer c0 = new Consumer(r);
            Consumer c1 = new Consumer(r);
            //创建线程
            Thread tp0 = new Thread(p0);
            Thread tp1 = new Thread(p1);
            Thread tc0 = new Thread(c0);
            Thread tc1 = new Thread(c1);
            //开启线程
            tp0.start();
            tp1.start();
            tc0.start();
            tc1.start();
        }
    }

![结果：][20160426165913028]

[20160426165941295]: /images/20220724/7c12e21ed57b4f87a176d1f3096f1368.png
[20160426165913028]: /images/20220724/2038477d79cb421d9e75d9e3c8db77ea.png

发表评论取消回复

表情：

评论列表（有 0 条评论，8人围观）

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

相关阅读

相关 Java多线程同步：生产者消费者问题示例

在Java中，多线程的同步通常通过各种锁机制来实现，这里以经典的“生产者消费者”问题为例进行说明。 1. **类定义**： ```java // 生产者类 class Pro

喜欢ヅ旅行/ 2024年10月18日 19:18/ 0 赞/ 48 阅读

相关 Linux多线程——生产消费者模型概念和C++模拟实现生产消费者模型

Linux多线程——生产消费者模型概念和C++模拟实现生产消费者模型一、生产消费者模型 1.1 什么是生产消费者模型？ 1.2 为什么使

柔情只为你懂/ 2023年01月15日 15:24/ 0 赞/ 166 阅读

相关 Java多线程Day11-多线程之生产者消费者

生产者消费者问题生产者消费者模型生产者消费者实现生产者消费者模型生产者消费者模型包括生产者,消费者,仓库,产品:

女爷i/ 2022年12月07日 11:44/ 0 赞/ 218 阅读

相关多线程-生产消费者模式

package com.thread.cusproform; ```java / @Author yg_wu @Des

你的名字/ 2022年09月03日 08:24/ 0 赞/ 171 阅读

相关 Java线程之1.5版新特性多生产者多消费者（四）

在Java1.5以前的版本中，因为监视器是来自于Object，为了线程的互斥访问，用的synchronized方法或者模块在synchronized中，“锁”的操作是

墨蓝/ 2022年08月21日 10:40/ 0 赞/ 5 阅读

相关 Java线程之1.4版多生产多消费者示例（三）

多生产者，多消费者从单生产者单消费者示例进化而来注意两个变化的地方：为判断标记任务循环体的if—->while 为避免死锁唤醒notify–>not

心已赠人/ 2022年08月21日 09:48/ 0 赞/ 9 阅读

相关 Java多线程-生产消费者2

有关Java多线程-生产消费者，一个生产，多个线程消费，下面的代码模拟了整个过程，以及多线程中condition的用法。 ![工作原理][20160713220900448]

阳光穿透心脏的1/2处/ 2022年07月21日 05:44/ 0 赞/ 206 阅读

相关 Java多线程14：生产者/消费者模型

转自：http://www.cnblogs.com/xrq730/p/4855663.html 什么是生产者/消费者模型一种重要的模型，基于等待/通知机制。生产

旧城等待，/ 2022年05月25日 07:39/ 0 赞/ 201 阅读

相关 Java提高——多线程（五）生产消费者问题

生产者/消费者问题是个典型的多线程问题，类似于hello world对于一门编程语言而言，涉及的对象包括“生产者”、“消费者”、“仓库”和“产品”。该模型需要注意以下几点：

男娘i/ 2022年05月25日 02:57/ 0 赞/ 135 阅读

相关 Java多线程之线程通信之生产者消费者阻塞队列版

Java多线程之线程通信之生产者消费者传统版和阻塞队列版 -------------------- 目录 1. 线程通信之生产者消费者传统版 2. 线程通信之

深藏阁楼爱情的钟/ 2022年01月26日 10:45/ 0 赞/ 229 阅读