文档章节

并发编程实战 2.2. 生产者消费者 - wait() notifyAll()

火犀牛
 火犀牛
发布于 2016/05/14 16:19
字数 1240
阅读 1
收藏 0

//todo : 解释 wait() notifyAll()

 范例: 生产者消费者

Storage

package com.rr.current2.c2_3_product_consumer.test;

import java.util.concurrent.TimeUnit;

/**
 * Created by Isaac on 16-5-14.
 */
public class Storage {
    private int count;
    private int size;

    public Storage(int size) {
        this.size = size;
    }

    //添加产品
    public synchronized void addProduct() {
        while (count >= size) {
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        try {
            TimeUnit.MILLISECONDS.sleep(100);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        count += 1;
        notifyAll();
        System.out.println("添加食物: " + count);
    }

    public synchronized void getProduct() {
        while (count <= 0) {
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

        try {
            TimeUnit.MILLISECONDS.sleep(100);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        count -= 1;
        notifyAll();
        System.out.println("获取食物: " + count);
    }
}

生产者

package com.rr.current2.c2_3_product_consumer.test;

/**
 * Created by Isaac on 16-5-14.
 */
public class Producer implements Runnable {

    Storage storage;

    public Producer(Storage storage) {
        this.storage = storage;
    }

    //生产者负责生产
    @Override
    public void run() {

        for (int i = 0, len = 100; i < len; i++) {
            storage.addProduct();
        }
    }
}

消费者

package com.rr.current2.c2_3_product_consumer.test;

/**
 * Created by Isaac on 16-5-14.
 */
public class Customer implements Runnable {
    //消费者负责取东西
    Storage storage;

    public Customer(Storage storage) {
        this.storage = storage;
    }

    //生产者负责生产
    @Override
    public void run() {

        for (int i = 0, len = 100; i < len; i++) {
            storage.getProduct();
        }
    }
}

结果:

Main start!
添加食物: 1
添加食物: 2
添加食物: 3
添加食物: 4
添加食物: 5
添加食物: 6
添加食物: 7
添加食物: 8
添加食物: 9
添加食物: 10
获取食物: 9
获取食物: 8
获取食物: 7
获取食物: 6
获取食物: 5
获取食物: 4
获取食物: 3
获取食物: 2
获取食物: 1
获取食物: 0
添加食物: 1
添加食物: 2
添加食物: 3
添加食物: 4
添加食物: 5
添加食物: 6
添加食物: 7
添加食物: 8
添加食物: 9
添加食物: 10
获取食物: 9
获取食物: 8
获取食物: 7
获取食物: 6
获取食物: 5
获取食物: 4
获取食物: 3
获取食物: 2
获取食物: 1
获取食物: 0
添加食物: 1
添加食物: 2
添加食物: 3
添加食物: 4
添加食物: 5
添加食物: 6
添加食物: 7
添加食物: 8
添加食物: 9
添加食物: 10
获取食物: 9
获取食物: 8
获取食物: 7
获取食物: 6
获取食物: 5
获取食物: 4
获取食物: 3
获取食物: 2
获取食物: 1
获取食物: 0
添加食物: 1
添加食物: 2
添加食物: 3
添加食物: 4
添加食物: 5
添加食物: 6
添加食物: 7
添加食物: 8
添加食物: 9
添加食物: 10
获取食物: 9
获取食物: 8
获取食物: 7
获取食物: 6
获取食物: 5
获取食物: 4
获取食物: 3
获取食物: 2
获取食物: 1
获取食物: 0
添加食物: 1
添加食物: 2
添加食物: 3
添加食物: 4
添加食物: 5
添加食物: 6
添加食物: 7
添加食物: 8
添加食物: 9
添加食物: 10
获取食物: 9
获取食物: 8
获取食物: 7
获取食物: 6
获取食物: 5
获取食物: 4
获取食物: 3
获取食物: 2
获取食物: 1
获取食物: 0
添加食物: 1
添加食物: 2
添加食物: 3
添加食物: 4
添加食物: 5
添加食物: 6
添加食物: 7
添加食物: 8
添加食物: 9
添加食物: 10
获取食物: 9
获取食物: 8
获取食物: 7
获取食物: 6
获取食物: 5
获取食物: 4
获取食物: 3
获取食物: 2
获取食物: 1
获取食物: 0
添加食物: 1
添加食物: 2
添加食物: 3
添加食物: 4
添加食物: 5
添加食物: 6
添加食物: 7
添加食物: 8
添加食物: 9
添加食物: 10
获取食物: 9
获取食物: 8
获取食物: 7
获取食物: 6
获取食物: 5
获取食物: 4
获取食物: 3
获取食物: 2
获取食物: 1
获取食物: 0
添加食物: 1
添加食物: 2
添加食物: 3
添加食物: 4
添加食物: 5
添加食物: 6
添加食物: 7
添加食物: 8
添加食物: 9
添加食物: 10
获取食物: 9
获取食物: 8
获取食物: 7
获取食物: 6
获取食物: 5
获取食物: 4
获取食物: 3
获取食物: 2
获取食物: 1
获取食物: 0
添加食物: 1
添加食物: 2
添加食物: 3
添加食物: 4
添加食物: 5
添加食物: 6
添加食物: 7
添加食物: 8
添加食物: 9
添加食物: 10
获取食物: 9
获取食物: 8
获取食物: 7
获取食物: 6
获取食物: 5
获取食物: 4
获取食物: 3
获取食物: 2
获取食物: 1
获取食物: 0
添加食物: 1
添加食物: 2
添加食物: 3
添加食物: 4
添加食物: 5
添加食物: 6
添加食物: 7
添加食物: 8
添加食物: 9
添加食物: 10
获取食物: 9
获取食物: 8
获取食物: 7
获取食物: 6
获取食物: 5
获取食物: 4
获取食物: 3
获取食物: 2
获取食物: 1
获取食物: 0
Main end!

 

© 著作权归作者所有

共有 人打赏支持
火犀牛
粉丝 0
博文 27
码字总数 12180
作品 0
海淀
程序员
私信 提问
Java实现生产者-消费者模型

考查Java的并发编程时,手写“生产者-消费者模型”是一个经典问题。有如下几个考点: 对Java并发模型的理解 对Java并发编程接口的熟练程度 bug free coding style JDK版本:oracle java 1.8...

monkeysayhi
2017/11/20
0
0
Java实现生产者-消费者模型

考查Java的并发编程时,手写“生产者-消费者模型”是一个经典问题。有如下几个考点: 对Java并发模型的理解 对Java并发编程接口的熟练程度 bug free coding style JDK版本:oracle java 1.8...

猴子007
2017/10/16
0
0
Java并发编程初级篇(十六):Lock+Condition实现生产者消费者问题

之前我们在“Java并发编程初级篇(十二):使用wait和notify生产者消费者问题”,已经使用Java提供的synchronized关键字和wait(),notify(),notifyAll()方法实现过来生产者消费者问题。Java ...

阿拉德大陆的魔法师
2016/11/25
18
0
wait()&nitifyAll()简单工作调度

多线程模型其实用得最多的就是生产者-消费者模式,其实现在流行的异步执行也是在这基础上发展起来的。其实问题的关键就是一句话,如何保证多线程任务能够按一定的顺序执行,因为实际的问题往...

Acce1erator
2016/12/13
37
0
如何在 Java 中正确使用 wait, notify 和 notifyAll – 以生产者消费者模型为例

wait, notify 和 notifyAll,这些在多线程中被经常用到的保留关键字,在实际开发的时候很多时候却并没有被大家重视。本文对这些关键字的使用进行了描述。 在 Java 中可以用 wait、notify 和 ...

牧师-Panda
2016/10/20
21
0

没有更多内容

加载失败,请刷新页面

加载更多

Jmeter参数的AES加密使用

在Jmeter日常实践中,大家应该都遇到过接口传参需要加密的情况。以登陆为例,用户名和密码一般都需要进行加密传输,在服务端再进行解密,这样安全系数会更高,但在使用jmeter进行接口测试的时...

程序猿拿Q
15分钟前
0
0
MYSQL 日期函数 Date and Time Functions

Table 12.13 Date and Time Functions Name Description ADDDATE() Add time values (intervals) to a date value ADDTIME() Add time CONVERT_TZ() Convert from one time zone to another ......

_liucui_
22分钟前
0
0
Android代码混淆ProGuard工作原理简介

ProGuard能够对Java类中的代码进行压缩(Shrink),优化(Optimize),混淆(Obfuscate),预检(Preveirfy)。    1. 压缩(Shrink): 在压缩处理这一步中,用于检测和删除没有使用的类,字段...

SuShine
24分钟前
0
0
Idea 2018激活

教程地址: https://www.52pojie.cn/thread-781394-1-1.html 亲测可用

一个不正经的程序员
30分钟前
0
0
Android组件化开发实践和案例分享

目录介绍 1.为什么要组件化 1.1 为什么要组件化 1.2 现阶段遇到的问题 2.组件化的概念 2.1 什么是组件化 2.2 区分模块化与组件化 2.3 组件化优势好处 2.4 区分组件化和插件化 2.5 applicatio...

潇湘剑雨
30分钟前
0
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部