生产者-消费者ArrayBlockingQueue是一个实现了BlockingQueue接口的类，其可以很方便的实现生产者-消费者模式。用法如下： class Producer implements Runnable { private final BlockingQueue queue; Prod ...
分类：
其他好文 时间：
2021-06-19 18:48:33
阅读次数：
0
#include <stdio.h> #include <string.h> #include <stdint.h> #include <errno.h> #include <sys/queue.h> #include <rte_launch.h> #include <rte_eal.h> #inc ...
分类：
其他好文 时间：
2021-06-17 16:28:03
阅读次数：
0
using System; using System.Collections.Generic; using System.Threading; namespace 生产者消费者 { class Program { static int r; static Queue<int> q = new Que ...
分类：
其他好文 时间：
2021-06-16 18:05:33
阅读次数：
0
一、JVM 二、Java集合 三、Java多线程并发 四、Java基础 五、Spring原理 六、微服务 七、Netty与RPC 八、网络 九、日志 十、RabbitMQ 十一、MongoDB 十二、设计模式 十三、负载均衡 十四、数据 十五、Java算法 十六、数据结构 十七、Hadoop 十八、 ...
分类：
编程语言 时间：
2021-06-13 10:00:32
阅读次数：
0
#include <cmath> #include <queue> #include <vector> #include <cstdio> #include <cstring> #include <iostream> #include <algorithm> #define ZYC using #d ...
分类：
其他好文 时间：
2021-06-13 09:59:25
阅读次数：
0
记录下本人在win10环境下安装RabbitMQ的步骤 第一步：下载并安装erlang 原因：RabbitMQ服务端代码是使用并发式语言Erlang编写的，安装Rabbit MQ的前提是安装Erlang。 下载地址：http://www.erlang.org/downloads 官网现在速度太慢，建 ...
在消息RabbitMQ时,我们关心的一个问题是手动ack还是自动ack,如果是自动ack就怕出现丢消息的情况 Flink以RabbitMQ作为Source,是怎么保证消息唯一性的呢,是怎么保证ack的. 首先引入依赖包 <dependency> <groupId>org.apache.flink</ ...
分类：
其他好文 时间：
2021-06-11 19:15:45
阅读次数：
0
使用QT 的信号与槽函数的过程，编译完成后，在运行程序是出现如下信息： QObject::connect: Cannot queue arguments of type 'myReadBuf'(Make sure 'myReadBuf' is registered using qRegisterMe ...
分类：
其他好文 时间：
2021-06-11 18:06:00
阅读次数：
0
docker run -di --name kaka-rabbit -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin -p 15672:15672 -p 5672:5672 -p 25672:25672 -p 61613:61 ...
分类：
其他好文 时间：
2021-06-11 17:46:06
阅读次数：
0
生产者： package com.gavin.mq.direct; import com.gavin.utils.RabbitMQUtils; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; imp ...
分类：
其他好文 时间：
2021-06-10 18:34:25
阅读次数：
0
