〇、rabbitMQ官方文档 https://www.rabbitmq.com/tutorials/tutorial-one-python.html 一、RabbitMQ 原理简介 1. RabbitMQ 角色 生产者：消息的创建者，负责创建和推送数据到消息服务器； 消费者：消息的接收方，用于处理数 ...
分类：
其他好文 时间：
2020-02-11 11:52:56
阅读次数：
70
增加了buffsize，生产者生产过多，wait #include <stdio.h> #include <unistd.h> #include <pthread.h> #define PRODUCER_SIZE 1 #define CONSUMER_SIZE 1 int products = 0; ...
分类：
其他好文 时间：
2020-02-09 16:28:51
阅读次数：
66
思路: 生产者判读是否大于20: 若 否,则生产一个产品并且唤醒(消费者).若是,则堵塞. 消费者判读是否大于0,若是,则消费一个产品,并唤醒(生产者).若否,则堵塞. 我们将生产和消费的方法,放到店员类,这样可以操作共享数据. package com.LearnJava.Thread; class ...
分类：
其他好文 时间：
2020-02-08 17:20:40
阅读次数：
78
前言 在大量消息的情况下 Kakfa 是如何保证消息的高效及一致性呢？ 正好以这个问题结合 Kakfa 的源码讨论下如何正确、高效的发送消息。 内容较多，对源码感兴趣的朋友请系好安全带??(源码基于 v0.10.0.0 版本分析)。同时最好是有一定的 Kafka 使用经验，知晓基本的用法。 简单的消 ...
分类：
其他好文 时间：
2020-02-07 12:40:43
阅读次数：
62
解决方式2： 并发协作模型"生产者/消费这模式"-->信号灯法 来判断一个标志位flag，如果为true，就让他等待、如果为false，就让他去通知另外一个人、把两人衔接起来，就像咱们的信号灯红灯停，绿灯行，通过这样一个判断方式，只要来判断什么瑞后让他等待，什么时候将他唤醒就ok。 1 packag ...
分类：
编程语言 时间：
2020-02-04 20:28:03
阅读次数：
75
解决方式1： 并发协作模型"生产者/消费者模式" >管程法 生产者：负责生产数据的模块(可能是方法，对象，线程，进程) 消费者：负责处理数据的模块(可能是方法，对象，线程，进程) 缓冲区：消费者不能直接使用生产者的数据，他们之间有个缓冲区，生产者将生产好的数据放入缓冲区，消费者从缓冲区拿出数据 思路 ...
分类：
编程语言 时间：
2020-02-04 20:15:16
阅读次数：
94
多线程在平时生活中很常见了，比如说平时打游戏为什么那么多人可以同时一块打互不影响。晚上打王者荣耀，你和你室友同时在开黑，你们两个如何做到相互能看到，又相互独立的去执行一些事情。我跟你聊天为什么你能够发消息的同时，我也能跟你发消息，咱们两东西用的是一样的啊，等等。多线程在现实生活中是非常常见的。 线程 ...
分类：
编程语言 时间：
2020-02-04 18:44:24
阅读次数：
90
两种模式：队列模式/主题模式 pom.xml <dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-all</artifactId> <version>5.15.9</version> </dependenc ...
分类：
其他好文 时间：
2020-01-30 20:56:55
阅读次数：
75
问题描述 产品 生产者 java package product; / 消费者 / public class Consumer implements Runnable{ private Storage storage = new Storage(); public Consumer(Storage ...
分类：
其他好文 时间：
2020-01-29 17:49:12
阅读次数：
66
