public BroadcastClusterInvoker(Directory<T> directory) { super(directory); int poolSize = directory.getUrl().getParameter("broadCastPoolSize", 8); par ...
分类：
编程语言 时间：
2020-01-04 14:17:42
阅读次数：
80
如果业务中，对于kafka发送消息异步消费的场景，在业务上需要实现在消费时实现顺序消费， 利用kafka在partition内消息有序的特点，消息消费时的有序性。 1、在发送消息时，通过指定partition hash 2、consumer 消费消息时，需要使用亲缘性线程池进行消费，才能实现消息的基 ...
分类：
其他好文 时间：
2020-01-04 14:13:35
阅读次数：
90
废话不多少说，直接开始： public class ThreadFactory { static class ThreadPoolTask implements Runnable, Serializable { private Object attachData; ThreadPoolTask(Ob ...
分类：
编程语言 时间：
2020-01-03 18:00:29
阅读次数：
86
问题描述： 运行结果：可见多线程运行是没有顺序的 方法1:join 解释：join源码中执行的是Object类中的wait方法。原理是让主线程处于wait，知道子线程执行结束才继续执行主线程。 方法2：利用单线程池Executors.newSingleThreadExecutor() ...
分类：
编程语言 时间：
2020-01-03 00:10:22
阅读次数：
90
1.线程池 import time from concurrent.futures import ThreadPoolExecutor def func(n): time.sleep(2) print(n) t_pool = ThreadPoolExecutor(max_workers=5) # 创 ...
分类：
编程语言 时间：
2020-01-02 20:35:31
阅读次数：
91
1. 引言 在新的 C++11 标准中，引入并发编程的一些基础组件： 线程（thread） 、 互斥锁（mutex） 、 条件变量（condition_variable） 等，凭借这些，就足够我设计一个平台无关的 线程池 组件了。下面就详细介绍一下这个线程池组件。 2. 结构设计图 需要特别说明的是 ...
分类：
编程语言 时间：
2020-01-01 23:31:48
阅读次数：
77
Thread和HandlerThread的差别 1）Handler：在Android中负责发送和处理消息，通过它可以实现其他支线线程与主线程之间的消通讯 2）Thread：线程，可以看作是进程的一个实体，是CPU调度和分派的基本单位，他是比进程更小的独立运行的基本单位 3）HandlerThread ...
分类：
移动开发 时间：
2020-01-01 19:10:12
阅读次数：
112
记录Java中的常见概念和原理 参考： https://www.cnblogs.com/fzz9/p/8973315.html https://blog.csdn.net/xinzhou201/article/details/81986594 面对对象的三个特点 封装：封装就是隐藏对象的属性和实现细 ...
分类：
编程语言 时间：
2019-12-31 01:48:01
阅读次数：
93
queue队列日，这篇好长啊….queue is especially useful in threaded programming when information must be exchanged safely between multiple threads.多线程编程环境下，当在多条线程中... ...
分类：
编程语言 时间：
2019-12-31 01:25:10
阅读次数：
118
