2021-03-09 12:56:09

前言在面对 生产者-消费者 的场景下， netcore 提供了一个新的命名空间 System.Threading.Channels 来帮助我们更高效的处理此类问题，有了这个 Channels 存在, 生产者 和 消费

2020-10-20 16:58:00

简介今天给大家介绍一下DelayQueue,DelayQueue是BlockingQueue的一种，所以它是线程安全的，DelayQueue的特点就是插入Queue中的数据可以按照自定义的delay时间进行排序。只有de

2020-10-16 14:58:09

这里使用 spring-kafka 依赖和 KafkaTemplate 对象来操作 Kafka 服务。一、添加依赖和添加配置项1.1、在 Pom 文件中添加依赖<dependency>  <groupId>org.springframework.k

2020-10-05 13:58:16

Condition的处理流程如下：首先acquire一个条件变量，然后判断一些条件。  如果条件不满足则wait；    如果条件满足，进行一些处理改变条件后，通过notify方法通知其他线程，其他处于wa

2020-09-28 08:58:31

1、生产者消费者模型作用和示例如下：1）通过平衡生产者的生产能力和消费者的消费能力来提升整个系统的运行效率 ，这是生产者消费者模型最重要的作用2）解耦，这是生产者消费者模型附

2020-09-01 12:56:18

本文实例讲述了PHP Beanstalkd消息队列的安装与使用方法。分享给大家供大家参考，具体如下：一、Beanstalkd是什么？Beanstalkd是一个高性能，轻量级的分布式内存队列二、Beanstalkd

2020-08-31 10:28:30

RabbitMQ    消息队列PYthreading Queue进程Queue 父进程与子进程，或同一父进程下的多个子进程进行交互缺点：两个不同Python文件不能通过上面两个Queue进行交互erlong基于这个

2020-08-07 19:18:16

channel有点类似于管道，它在goroutine同步与通信中，有着起承转合的作用，同时也是Golang实现CSP模型的关键。golang 中大部分类型都是值类型(只有 slice / channel / map 是引用

2020-08-05 13:48:48

序redis提供了简单的发布订阅功能，对于一些合适的场景(比如不要求消费者不在线时也能收到离线消息)，比起专业的MQ来说，用起来更简单些。本文主要是记录下怎么在SpringBoot里头

2020-07-30 17:38:01

有关Beanstalkd的基本概念，编译和yum的安装方法已经在上篇文章《Beanstalkd消息/任务队列的详解》中介绍了，今天练习下PHP使用Beanstalkd的过程，我选择的是使用Pheanstalk类来

2020-07-29 14:41:30

安装 Kafka 服务直接到 kafka 官网 , 下载最新的wget https://mirror.bit.edu.cn/apache/kafka/2.5.0/kafka_2.13-2.5.0.tgz解压，进入目录tar -zxvf kafka_2.13-2.5.0.tgzcd

2020-07-28 16:53:07

上一节记录了多线程技术以及Python多线程的的简单上手.毫无疑问,多线程是为了充分利用硬件资源尤其是CPU资源来提高任务处理效率的技术。将任务拆分为多个线程同时运行，那么

2020-07-24 19:00:14

生产者-消费者算是并发编程中常见的问题。依靠缓冲区我们可以实现生产者与消费者之间的解耦。生产者只管往缓冲区里面放东西，消费者只管往缓冲区里面拿东西。这样我们避免生