搜索结果
查询Tags标签： consumer，共有 108条记录-
Python | 面试的常客，经典的生产消费者模式
今天是Python专题的第23篇文章，我们来聊聊关于多线程的一个经典设计模式。在之前的文章当中我们曾经说道，在多线程并发的场景当中，如果我们需要感知线程之间的状态，交换线程之间的信息是一件非常复杂和困难的事情。因为我们没有更高级的系统权限，也没有上帝视角，很难…
2021/10/3 22:11:39 人评论 次浏览 -
Python | 面试的常客，经典的生产消费者模式
今天是Python专题的第23篇文章，我们来聊聊关于多线程的一个经典设计模式。在之前的文章当中我们曾经说道，在多线程并发的场景当中，如果我们需要感知线程之间的状态，交换线程之间的信息是一件非常复杂和困难的事情。因为我们没有更高级的系统权限，也没有上帝视角，很难…
2021/10/3 22:11:39 人评论 次浏览 -
BTAJ面试有关散列（哈希）表的面试题详解，Java技术篇
Kafka源码篇——Kafka快速入门 1.1Kafka简介1.2以Kafka为中心的解决方案1.3 Kafka核心概念1.4搭建Kafka源码环境Kafka源码篇——生产者 2.1 KafkaProducer使用示例2.2 KafkaProducer分析2.3 RecordAccumulator分析2.4 Sender分析Kafka源码篇——消费者 3.1 KafkaConsumer使…
2021/9/29 9:41:10 人评论 次浏览 -
BTAJ面试有关散列（哈希）表的面试题详解，Java技术篇
Kafka源码篇——Kafka快速入门 1.1Kafka简介1.2以Kafka为中心的解决方案1.3 Kafka核心概念1.4搭建Kafka源码环境Kafka源码篇——生产者 2.1 KafkaProducer使用示例2.2 KafkaProducer分析2.3 RecordAccumulator分析2.4 Sender分析Kafka源码篇——消费者 3.1 KafkaConsumer使…
2021/9/29 9:41:10 人评论 次浏览 -
RocketMQ源码解析十一（Consumer上报消费进度流程（集群模式））
RocketMQ版本4.6.0，记录自己看源码的过程Consumer 在消费者启动过程中，会启动MQClientInstance，而MQClientInstance中会启动多个定时任务，其中就包括定时上报消费进度： private void startScheduledTask() {// 省略其它定时任务。。。// 定时持久化消费进度，默认5st…
2021/9/28 17:11:15 人评论 次浏览 -
RocketMQ源码解析十一（Consumer上报消费进度流程（集群模式））
RocketMQ版本4.6.0，记录自己看源码的过程Consumer 在消费者启动过程中，会启动MQClientInstance，而MQClientInstance中会启动多个定时任务，其中就包括定时上报消费进度： private void startScheduledTask() {// 省略其它定时任务。。。// 定时持久化消费进度，默认5st…
2021/9/28 17:11:15 人评论 次浏览 -
java8 Consumer supplier predicate function 简单使用示例
java8 Consumer基本使用 Java8之后提供了consumer接口，Consumer字面意思是消费者，这个接口里面只有一个accept方法，主要的功能是消费输入的数据，无返回。主要的几种使用方式有以下几种：@Testpublic void testConsumer() {//1. 直接new一个consumer对象 ，实现里面的a…
2021/9/27 17:12:46 人评论 次浏览 -
java8 Consumer supplier predicate function 简单使用示例
java8 Consumer基本使用 Java8之后提供了consumer接口，Consumer字面意思是消费者，这个接口里面只有一个accept方法，主要的功能是消费输入的数据，无返回。主要的几种使用方式有以下几种：@Testpublic void testConsumer() {//1. 直接new一个consumer对象 ，实现里面的a…
2021/9/27 17:12:46 人评论 次浏览 -
Java8新特性 consumer
个人公众号，欢迎关注下：小蜗牛会飞 Java8新特性 consumerJava8的一个新特性-consumerhttps://mp.weixin.qq.com/s/YIddXxQvW18ic73O3Jl_0w 今天来聊聊Java8的一个新特性-consumer，这个是在项目中发现同事用过，所以就研究研究一下。 consumer从字面上面来理解就是消费的…
2021/9/20 20:34:12 人评论 次浏览 -
Java8新特性 consumer
个人公众号，欢迎关注下：小蜗牛会飞 Java8新特性 consumerJava8的一个新特性-consumerhttps://mp.weixin.qq.com/s/YIddXxQvW18ic73O3Jl_0w 今天来聊聊Java8的一个新特性-consumer，这个是在项目中发现同事用过，所以就研究研究一下。 consumer从字面上面来理解就是消费的…
2021/9/20 20:34:12 人评论 次浏览 -
java~并行计算~大集合的并行处理
上一次写了关于《FunctionalInterface~一个批量处理数据的类》和《Future和Callable实现大任务的并行处理》的文章，本讲主要结合实际应用，来封装一个集合并行处理组件，我们的集合分为数据库查询出现的分页集合；还有一个是内存的集合，今天主要说一下内存集合的并行处理…
2021/9/10 14:35:04 人评论 次浏览 -
java~并行计算~大集合的并行处理
上一次写了关于《FunctionalInterface~一个批量处理数据的类》和《Future和Callable实现大任务的并行处理》的文章，本讲主要结合实际应用，来封装一个集合并行处理组件，我们的集合分为数据库查询出现的分页集合；还有一个是内存的集合，今天主要说一下内存集合的并行处理…
2021/9/10 14:35:04 人评论 次浏览 -
Java8新特性-Lambda表达式，被spring相关问题虐哭了
// 4.返回值简写IRun run2 = () -> 10;run2.run();}} interface IEat { void eat(String thing);} interface ISpeak { void talk(String who, String content);} interface IRun { int run();}[]()案例3 final类型参数----------------------------------------------…
2021/9/9 14:04:14 人评论 次浏览 -
Java8新特性-Lambda表达式，被spring相关问题虐哭了
// 4.返回值简写IRun run2 = () -> 10;run2.run();}} interface IEat { void eat(String thing);} interface ISpeak { void talk(String who, String content);} interface IRun { int run();}[]()案例3 final类型参数----------------------------------------------…
2021/9/9 14:04:14 人评论 次浏览 -
如何获取 Kafka 的消费者详情？ —— 从 Scala 到 Java 的切换
目标及实现 实现如同 bin/kafka-consumer-group.sh –describe –bootstrap-server localhost:9092 –group CONSUMER_GROUP_ID的效果： [root@node2 kafka_2.12-1.0.0]# bin/kafka-consumer-groups.sh --describe --bootstrap-server localhost:9092 --group CONSUMER_GR…
2021/9/7 17:07:56 人评论 次浏览
