生产者消费模型-管程法

并发协作模型“生产者/消费者模式”—>管程法

生产者：负责生产数据的模块(可能是方法，对象，线程，进程)；
消费者：负责处理数据的模块(可能是方法，对象，线程，进程)；
缓冲区：消费者不能直接使用生产者的数据，他们之间有个“缓冲区”
生产者将生产好的数据放入缓冲区，消费者从缓冲区拿出数据

管程法案例

package Thread;import java.awt.*;//测试：生产者消费者模型--->利用缓冲区：管理法
public class TestPc {public static void main(String[] args) {synContainer container=new synContainer();new Productor(container).start();new Consumer(container).start();}}//生产者
class Productor extends Thread{synContainer container;public  Productor(synContainer container){this.container=container;}//生产public  void run(){for (int i = 0; i < 100; i++) {container.push(new Chicken(i));System.out.println("生产了"+i+"只鸡");}}
}//消费者
class Consumer extends Thread{synContainer container;public Consumer(synContainer container){this.container=container;}//消费public  void run(){for (int i = 0; i < 100; i++) {System.out.println("消费了--->"+container.pop().id+"只鸡");}}
}//产品
class  Chicken{//产品编号int id;public  Chicken(int id){this.id=id;}
}//缓冲区
class synContainer {//需要一个容器大小Chicken[] chickens=new Chicken[10];//容器计数器int count=0;//生产者放入产品public synchronized  void push(Chicken chicken){//如果容器满了,就需要等待消费者消费if (count==chickens.length){//通知消费者消费,生产等待try {this.wait();} catch (InterruptedException e) {e.printStackTrace();}}//如果没有满, 我们就需要丢入产品chickens[count]=chicken;count++;//可以通知消费者消费了。this.notifyAll();}//消费者消费产品public synchronized  Chicken pop(){//判断能否消费if(count==0){//等待生产者消费，消费者等待try {this.wait();} catch (InterruptedException e) {e.printStackTrace();}}//如果可以消费count--;Chicken chicken =chickens[count];//吃完了, 通知生产者生产this.notifyAll();return chicken;}}

生产者消费模型-管程法相关推荐

生产者消费者模型-管程法（Java）
生产者消费者模型-管程法(Java) package src.thread;//生产者消费者产品缓冲区 public class TestPC {public static void main( ...
利用互斥锁和条件变量实现生产者消费模型
以下内容全部来自于自旋锁_哔哩哔哩_bilibili #include <stdio.h> #include <pthread.h> #include <stdlib.h ...
用三个线程实现生产者消费者模型，其中一个线程作为生产者，二个线程作为消费者，生产者随机生产一个时间戳或者字符串，消费者消费这个时间戳，并不能重复消费，并将其打印出来
题目要求: 用三个线程实现生产者消费者模型,其中一个线程作为生产者,二个线程作为消费者,生产者随机生产一个时间戳或者字符串,消费者消费这个时间戳,并不能重复消费,并将其打印出来.(这是一道百度面试的算 ...
java 生产者消费者_Java多线程：线程间通信—生产者消费者模型
一.背景 && 定义多线程环境下,只要有并发问题,就要保证数据的安全性,一般指的是通过 synchronized 来进行同步. 另一个问题是, 多个线程之间如何协作呢 ? 我们看一个 ...
生产者/消费者模型详解（基于Java）
title: 生产者消费者模型 tags: 多线程 synchronized 锁 wait() notify() 生产者/消费者模型原理以及代码实现一.生产者/消费者模型原理所谓的生产者消费者模型 ...
java多线程抽奖_java 线程池、多线程并发实战(生产者消费者模型 1 vs 10) 附案例源码...
导读前二天写了一篇<Java 多线程并发编程>点我直达,放国庆,在家闲着没事,继续写剩下的东西,开干! 线程池为什么要使用线程池例如web服务器.数据库服务器.文件服务器或邮件服务器 ...
11.python并发入门（part8 基于线程队列实现生产者消费者模型）
一.什么是生产者消费者模型? 生产者就是生产数据的线程,消费者指的就是消费数据的线程. 在多线程开发过程中,生产者的速度比消费者的速度快,那么生产者就必须等待消费者把数据处理完,生产者才会产生新的数据 ...
线程同步之经典生产者-消费者模型
/* 线程同步之生产者-消费者模型该模型符合以下要求: 1.生产者只在仓储未满时生产,仓满则停止生产: 2.消费者只在仓储未空时消费,仓空则等待: 3.当消费者发现仓储为空时则通知生产者生产: 4. ...
Python之路(第三十八篇) 并发编程：进程同步锁/互斥锁、信号量、事件、队列、生产者消费者模型...
一.进程锁(同步锁/互斥锁) 进程之间数据不共享,但是共享同一套文件系统,所以访问同一个文件,或同一个打印终端,是没有问题的, 而共享带来的是竞争,竞争带来的结果就是错乱,如何控制,就是加锁处理. 例 ...

生产者消费模型-管程法

生产者消费模型-管程法相关推荐

最新文章

热门文章