文档章节

并发编程实战 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

没有更多内容

加载失败,请刷新页面

加载更多

Sentry使用

Sentry使用 以django为例.实际上sentry本身文档已经有介绍了.这里只是再总结 1、全局异常捕获 此方法可以全局捕获任何的异常(甚至包括你自己raise的异常),在实际使用过程中不太推荐.但胜在快...

_Change_
31分钟前
1
0
linux系统包管理工具详解 yum rpm apt-get pip wget

在Linux系统下,根据系统版本的不同会有各种各样的包管理工具,下面就简单的梳理一下这几种安装命令. 1、yum Yum(全称为 Yellow dog Updater, Modified)是一个在Fedora、RedHat、CentOS中的...

huoyoung
34分钟前
1
0
阿里巴巴Dubbo实现的源码分析

1. Dubbo概述 Dubbo是阿里巴巴开源出来的一个分布式服务框架,致力于提供高性能和透明化的RPC远程服务调用方案,以及作为SOA服务治理的方案。它的核心功能包括: #remoting:远程通讯基础,提...

别打我会飞
35分钟前
8
0
tomcat的maxThreads、acceptCount(最大线程数、最大排队数)

tomcat 6的Connector配置如下: <Connector port="8080" protocol="HTTP/1.1" connectionTimeout="20000" redirectPort="8443" maxThreads......

为了美好的明天
38分钟前
3
0
阿里P9架构师谈:高并发网站的监控系统选型、比较、核心监控指标

在高并发分布式环境下,对于访问量大的业务、接口等,需要及时的监控网站的健康程度,防止网站出现访问缓慢,甚至在特殊情况出现应用服务器雪崩等场景,在高并发场景下网站无法正常访问的情况...

架构师springboot
38分钟前
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部