文档章节

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

没有更多内容

加载失败,请刷新页面

加载更多

C++ std::function 和 std::bind

C++11提供了std::function和std::bind两个工具,用于引用可调用对象。这些可调用对象包括 普通函数,Lambda表达式,类的静态成员函数,非静态成员函数以及仿函数等。引用可调用对象,可以用于...

yepanl
14分钟前
0
0
python:可迭代对象的索引

关于 python的range的用法: 注意是[ 开始,结束)的半开区间,不包括结束 http://www.runoob.com/python/python-func-range.html 字符串 = "一二三四五六七八九十"for i in range(-1, -11, -1...

Oh_really
28分钟前
1
0
docker-compose ,docker-stack

1.例子 version: "3"services: php: image: registry.cn-hangzhou.aliyuncs.com/lxepoo/apache-php5 ports: - "38080:80" networks: - my_php_mysql volum......

chenbaojun
37分钟前
2
0
SQL_Server2000示例数据库NorthWind的分析(转)

SQL_Server2000示例数据库NorthWind的分析 表名:Categories(食品类别表) 表结构: 字段名称 数据类型 长度 允许为空 CategoryID(主键) int 4 否 CategoryName nvarchar 15 否 Description ...

QQZZFT
39分钟前
1
0
laravel 5.5 Session store not set on request.

laravel 5.5 数据存入session,会出现Session store not set on request.错误。查了下laravel 5.5将session放到global middleware中,需要laravel的文件 ./app/Http/Kernel.php中的加上一句:...

MichaelShu
今天
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部