java线程“生产/消费”模型2


/*  资源类 */
class ShareValue {private int total;//判断对象是否为空private boolean isEmpty=true;//判断对象是否已满private boolean isFull=true;public ShareValue(int total) {this.total = total;if(total>0) isEmpty=false;if(total<1000) isFull=false;}/** synchronized 方法控制对类成员变量的访问：每个类实例对应一把锁，每个 synchronized 方法都必须获得调用该方法的类实例的锁方能执行，* 否则所属线程阻塞，方法一旦执行，就独占该锁，直到从该方法返回时才将锁释放，此后被阻塞的线程方能获得该锁，重新进入可执行状态。* 这种机制确保了同一时刻对于每一个类实例，其所有声明为 synchronized 的成员函数中至多只有一个处于可执行状态* （因为至多只有一个能够获得该类实例对应的锁），从而有效避免了类成员变量的访问冲突（只要所有可能访问类成员变量的方法均被声明为 synchronized）。* */synchronized void putValue(int value){//取得当前线程名String name=Thread.currentThread().getName();while(isFull){display("Full ! ["+name+"] waites.");try {this.wait();} catch (InterruptedException e) {System.out.println(e);}}total+=value;if(total>1000){isFull=true;}display(name+",put: "+value+",old value: "+(total-value)+",now value"+total);isEmpty=false;//通知所有的等待线程notifyAll();}synchronized int getValue(int value){String  name=Thread.currentThread().getName();while(isEmpty || total<value){display("Empty or not enough! ["+name+"] waits.");            try {//进入等待状态this.wait();} catch (InterruptedException e) {System.out.println(e);}}display(name+" get: "+value+",old value:"+total+",now value :"+(total-value));if(total-value>=0){total-=value;}if(total==0){isEmpty=true;}if(total<1000){isFull=false;}//通知所有等待的线程notifyAll();return value;}int getNowTotal(){return total;}private void display(String string) {System.out.println(string);}
}/*  生产者类  */
class Producer extends Thread {// 共享的ShareValue对象ShareValue share;// 要增加的值int value;public Producer(String name, ShareValue share, int value) {super(name);this.share = share;this.value = value;}public void run() {//同步share对象 ，直到当前代码块运行完毕后，share的对象锁才会释放synchronized (share) {try {sleep(100);} catch (InterruptedException e) {System.out.println(e);}share.putValue(value);}}
}/*消费者类*/
class Consumer extends Thread{//共享的ShareValue对象ShareValue share;//要减少的值int value;public Consumer(String name,ShareValue share, int value) {super(name);this.share = share;this.value = value;}public void run(){  //同步share对象，直到当前代码运行完毕后，share的对象锁才会释放synchronized (share) {try {sleep(100);} catch (InterruptedException e) {System.out.println(e);}share.getValue(value);}}
} /*  测试主类  */
public class TestDemo {public static void main(String[] args) {ShareValue share=new ShareValue(0);Producer producer1=new Producer("producer1", share, 100);Consumer consumer=new Consumer("consumer", share, 300);Producer producer2=new Producer("producer2",share,950);Producer producer3=new Producer("producer3",share,50);
//      Producer producer4=new Producer("producer4",share,50);
//      Producer producer5=new Producer("producer5",share,50);producer1.start();consumer.start();producer2.start();producer3.start();
//      producer4.start();
//      producer5.start();}}

java线程“生产/消费”模型2相关推荐

java 线程“生产/消费”模型1
/*资源类*/ public class ShareValue {private int total;public ShareValue(int total){this.total=total;}// ...
Java实现生产消费模型的5种方式
** 前言 ** 生产者和消费者问题是线程模型中的经典问题:生产者和消费者在同一时间段内共用同一个存储空间,生产者往存储空间中添加产品,消费者从存储空间中取走产品,当存储空间为空时,消费者阻塞,当存储 ...
生产-消费模型之阻塞队列的源码分析
文章目录前言阻塞队列API 存放元素 boolean add(E e) boolean offer(E e) boolean offer(E e, long timeout, TimeUnit u ...
java生产消费模型代码实现_生产者-消费者模型的Java实现
本文转自:http://tanlan.iteye.com/blog/1158154 生产者-消费者(producer-consumer)问题,也称作有界缓冲区(bounded-buffer)问题,两个 ...
java 运动的大球吃小球_JAVA 多线程制作大球吃小球一、实现球的自动生成及运动生产消费模型...
/*文章中用到的代码只是一部分,需要源码的可通过邮箱联系我 [email protected]*/ 前几天用多线程实现了创建小球并移动,想到大鱼吃小鱼,便突发奇想要写一个大球吃小球.首先第一步自然是先 ...
java线程的内存模型_java多线程内存模型
java多线程内存模型: 可见性要实现共享变量的可见性,必须保证两点: 1.线程修改后的共享变量能够及时从工作内存刷新到主内存中: 2.其他线程能够及时把共享变量的最新值从主内存更新到自己的工作内存 ...
Python 多进程笔记 — 启动进程的方式、守护进程、进程间通信、进程池、进程池之间通信、多进程生产消费模型
1 面向过程启动多进程 Python 操作进程的类都定义在 multiprocessing 模块,该模块提供了一个 Process 类来代表一个进程对象,这个对象可以理解为是一个独立的进程,可以执行另 ...
23.生产与消费模型
实际生活中,需要操作共享的某个资源(水池),但是对这个共享资源的操作方式不同(部分是注水[生产].部分是抽水[消费]).把这种现象我们可以称为生产和消费模型. 生产:它可以采用部分线程进行模拟.多个线 ...
Java线程安全队列Queue实现原理
原文链接:https://www.cnblogs.com/DreamRecorder/p/9223016.html 在Java多线程应用中,队列的使用率很高,多数生产消费模型的首选数据结构就是队列.J ...

java线程“生产/消费”模型2

java线程“生产/消费”模型2相关推荐

最新文章

热门文章