[转载] --- 让线程按顺序执行8种方法

看到一篇比较用心的总结,涉及到很多知识点,转来保存,而且我把里面的每个方法都试了一遍,亲测没问题

此次转载,还新增了一些说明和结构

我的总结:

其实,让线程按顺序执行,其实就是一个让多线程强行串行化的过程。使用的场景比较少,但对于学习这些知识点,确实是一个好的切入口,通过这个可以清晰的感觉到,线程直接的互相等待,互相制约。
对于我来说,平时使用CountDownLatch的次数最多。


一、前言

本文使用了8种方法实现在多线程中让线程按顺序运行的方法,涉及到多线程中许多常用的方法,不止为了知道如何让线程按顺序运行,更是让读者对多线程的使用有更深刻的了解。

使用的方法如下:

1.1、使用线程的join方法

当一个线程必须等待另一个线程执行完毕才能执行时可以使用join方法。

1.2、使用主线程的join方法

在父进程调用子进程的join()方法后,父进程需要等待子进程运行完再继续运行。

1.3、使用线程的wait方法

Java实现生产者消费者的方式。

1.4、使用线程的线程池方法

线程池的相关解释可以看我这篇文章
串行执行所有任务。如果这个唯一的线程因为异常结束,那么会有一个新的线程来替代它。此线程池保证所有任务的执行顺序按照任务的提交顺序执行。

1.5、使用线程的Condition(条件变量)方法

Condition是一个多线程间协调通信的工具类,使得某个,或者某些线程一起等待某个条件(Condition),只有当该条件具备( signal 或者 signalAll方法被带调用)时 ,这些等待线程才会被唤醒,从而重新争夺锁。

1.6、使用线程的CountDownLatch(倒计数)方法

比如有一个任务C,它要等待其他任务A,B执行完毕之后才能执行,此时就可以利用CountDownLatch来实现这种功能了。

1.7、使用线程的CyclicBarrier(回环栅栏)方法

公司组织春游,等待所有的员工到达集合地点才能出发,每个人到达后进入barrier状态。都到达后,唤起大家一起出发去旅行。

1.8、使用线程的Semaphore(信号量)方法

Semaphore可以用来做流量分流,特别是对公共资源有限的场景,比如数据库连接。假设有这个的需求,读取几万个文件的数据到数据库中,由于文件读取是IO密集型任务,可以启动几十个线程并发读取,但是数据库连接数只有10个,这时就必须控制最多只有10个线程能够拿到数据库连接进行操作。这个时候,就可以使用Semaphore做流量控制。

二、实现

我们下面需要完成这样一个应用场景:

1.早上;2.测试人员、产品经理、开发人员陆续的来公司上班;3.产品经理规划新需求;4.开发人员开发新需求功能;5.测试人员测试新功能。

规划需求,开发需求新功能,测试新功能是一个有顺序的,我们把thread1看做产品经理,thread2看做开发人员,thread3看做测试人员。

2.1 使用线程的join方法

join():是Theard的方法,作用是调用线程需等待该join()线程执行完成后,才能继续用下运行。

应用场景:当一个线程必须等待另一个线程执行完毕才能执行时可以使用join方法。

package com.线程;/*** @Auther: curry.zhang* @Date: 2019/9/23 16:04* @Description: 通过子程序join使线程按顺序执行*/
public class ThreadJoinDemo {public static void main(String[] args) {final Thread thread1 = new Thread(new Runnable() {@Overridepublic void run() {System.out.println("产品经理规划新需求");}});final Thread thread2 = new Thread(new Runnable() {@Overridepublic void run() {try {thread1.join();System.out.println("开发人员开发新需求功能");} catch (InterruptedException e) {e.printStackTrace();}}});Thread thread3 = new Thread(new Runnable() {@Overridepublic void run() {try {thread2.join();System.out.println("测试人员测试新功能");} catch (InterruptedException e) {e.printStackTrace();}}});System.out.println("早上:");System.out.println("测试人员来上班了...");thread3.start();System.out.println("产品经理来上班了...");thread1.start();System.out.println("开发人员来上班了...");thread2.start();}
}

运行结果:

早上:
测试人员来上班了...
产品经理来上班了...
开发人员来上班了...
产品经理规划新需求
开发人员开发新需求功能
测试人员测试新功能

2.2、使用主线程的join方法

这里是在主线程中使用join()来实现对线程的阻塞。

在父进程调用子进程的join()方法后,父进程需要等待子进程运行完再继续运行。

package com.线程;/*** @Auther: curry.zhang* @Date: 2019/9/23 16:43* @Description: 通过主程序join使线程按顺序执行*/
public class ThreadMainJoinDemo {public static void main(String[] args) throws Exception {final Thread thread1 = new Thread(new Runnable() {@Overridepublic void run() {System.out.println("产品经理正在规划新需求...");}});final Thread thread2 = new Thread(new Runnable() {@Overridepublic void run() {System.out.println("开发人员开发新需求功能");}});final Thread thread3 = new Thread(new Runnable() {@Overridepublic void run() {System.out.println("测试人员测试新功能");}});System.out.println("早上:");System.out.println("产品经理来上班了");System.out.println("测试人员来上班了");System.out.println("开发人员来上班了");thread1.start();//在父进程调用子进程的join()方法后,父进程需要等待子进程运行完再继续运行。System.out.println("开发人员和测试人员休息会...");thread1.join();System.out.println("产品经理新需求规划完成!");thread2.start();System.out.println("测试人员休息会...");thread2.join();thread3.start();}
}

运行结果:

早上:
产品经理来上班了
测试人员来上班了
开发人员来上班了
开发人员和测试人员休息会...
产品经理正在规划新需求...
产品经理新需求规划完成!
测试人员休息会...
开发人员开发新需求功能
测试人员测试新功能

2.3、使用线程的wait方法

wait():是Object的方法,作用是让当前线程进入等待状态,同时,wait()也会让当前线程释放它所持有的锁。“直到其他线程调用此对象的 notify() 方法或 notifyAll() 方法”,当前线程被唤醒(进入“就绪状态”)

notify()和notifyAll():是Object的方法,作用则是唤醒当前对象上的等待线程;notify()是唤醒单个线程,而notifyAll()是唤醒所有的线程。

wait(long timeout):让当前线程处于“等待(阻塞)状态”,“直到其他线程调用此对象的notify()方法或 notifyAll() 方法,或者超过指定的时间量”,当前线程被唤醒(进入“就绪状态”)。

应用场景:Java实现生产者消费者的方式。

package com.线程;/*** @Auther: curry.zhang* @Date: 2019/9/23 16:48* @Description:*/
public class ThreadWaitDemo {private static Object myLock1 = new Object();private static Object myLock2 = new Object();/*** 为什么要加这两个标识状态?* 如果没有状态标识,当t1已经运行完了t2才运行,t2在等待t1唤醒导致t2永远处于等待状态*/private static Boolean t1Run = false;private static Boolean t2Run = false;public static void main(String[] args) {final Thread thread1 = new Thread(new Runnable() {@Overridepublic void run() {synchronized (myLock1){System.out.println("产品经理规划新需求...");t1Run = true;myLock1.notify();}}});final Thread thread2 = new Thread(new Runnable() {@Overridepublic void run() {synchronized (myLock1){try {if(!t1Run){System.out.println("开发人员先休息会...");myLock1.wait();}synchronized (myLock2){System.out.println("开发人员开发新需求功能");myLock2.notify();}} catch (InterruptedException e) {e.printStackTrace();}}}});Thread thread3 = new Thread(new Runnable() {@Overridepublic void run() {synchronized (myLock2){try {if(!t2Run){System.out.println("测试人员先休息会...");myLock2.wait();}System.out.println("测试人员测试新功能");} catch (InterruptedException e) {e.printStackTrace();}}}});System.out.println("早上:");System.out.println("测试人员来上班了...");thread3.start();System.out.println("产品经理来上班了...");thread1.start();System.out.println("开发人员来上班了...");thread2.start();}
}

运行结果:

早上:
测试人员来上班了...
产品经理来上班了...
开发人员来上班了...
产品经理规划新需求...
测试人员先休息会...
开发人员开发新需求功能
测试人员测试新功能

2.4、使用线程的线程池方法

JAVA通过Executors提供了四种线程池

单线程化线程池(newSingleThreadExecutor);
可控最大并发数线程池(newFixedThreadPool);
可回收缓存线程池(newCachedThreadPool);
支持定时与周期性任务的线程池(newScheduledThreadPool)。
单线程化线程池(newSingleThreadExecutor):优点,串行执行所有任务。

submit():提交任务。

shutdown():方法用来关闭线程池,拒绝新任务。

应用场景:串行执行所有任务。如果这个唯一的线程因为异常结束,那么会有一个新的线程来替代它。此线程池保证所有任务的执行顺序按照任务的提交顺序执行。

package com.线程;import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;/*** @Auther: curry.zhang* @Date: 2019/9/23 16:52* @Description: 通过SingleThreadExecutor让线程按顺序执行*/
public class ThreadPoolDemo {static ExecutorService executorService = Executors.newSingleThreadExecutor();public static void main(String[] args) throws Exception {final Thread thread1 = new Thread(new Runnable() {@Overridepublic void run() {System.out.println("产品经理规划新需求");}});final Thread thread2 = new Thread(new Runnable() {@Overridepublic void run() {System.out.println("开发人员开发新需求功能");}});Thread thread3 = new Thread(new Runnable() {@Overridepublic void run() {System.out.println("测试人员测试新功能");}});System.out.println("早上:");System.out.println("产品经理来上班了");System.out.println("测试人员来上班了");System.out.println("开发人员来上班了");System.out.println("领导吩咐:");System.out.println("首先,产品经理规划新需求...");executorService.submit(thread1);System.out.println("然后,开发人员开发新需求功能...");executorService.submit(thread2);System.out.println("最后,测试人员测试新功能...");executorService.submit(thread3);executorService.shutdown();}
}

运行结果:

早上:
产品经理来上班了
测试人员来上班了
开发人员来上班了
领导吩咐:
首先,产品经理规划新需求...
然后,开发人员开发新需求功能...
最后,测试人员测试新功能...
产品经理规划新需求
开发人员开发新需求功能
测试人员测试新功能

2.5、使用线程的Condition(条件变量)方法

Condition(条件变量):通常与一个锁关联。需要在多个Contidion中共享一个锁时,可以传递一个Lock/RLock实例给构造方法,否则它将自己生成一个RLock实例。

Condition中await()方法类似于Object类中的wait()方法。

Condition中await(long time,TimeUnit unit)方法类似于Object类中的wait(long time)方法。

Condition中signal()方法类似于Object类中的notify()方法。

Condition中signalAll()方法类似于Object类中的notifyAll()方法。

应用场景:Condition是一个多线程间协调通信的工具类,使得某个,或者某些线程一起等待某个条件(Condition),只有当该条件具备( signal 或者 signalAll方法被带调用)时 ,这些等待线程才会被唤醒,从而重新争夺锁。

package com.线程;import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;/*** @Auther: curry.zhang* @Date: 2019/9/23 17:02* @Description: 使用Condition(条件变量)实现线程按顺序运行*/
public class ThreadConditionDemo {private static Lock lock = new ReentrantLock();private static Condition condition1 = lock.newCondition();private static Condition condition2 = lock.newCondition();/*** 为什么要加这两个标识状态?* 如果没有状态标识,当t1已经运行完了t2才运行,t2在等待t1唤醒导致t2永远处于等待状态*/private static Boolean t1Run = false;private static Boolean t2Run = false;public static void main(String[] args) {final Thread thread1 = new Thread(new Runnable() {@Overridepublic void run() {lock.lock();System.out.println("产品经理规划新需求");t1Run = true;condition1.signal();lock.unlock();}});final Thread thread2 = new Thread(new Runnable() {@Overridepublic void run() {lock.lock();try {if(!t1Run){System.out.println("开发人员先休息会...");condition1.await();}System.out.println("开发人员开发新需求功能");t2Run = true;condition2.signal();} catch (InterruptedException e) {e.printStackTrace();}lock.unlock();}});Thread thread3 = new Thread(new Runnable() {@Overridepublic void run() {lock.lock();try {if(!t2Run){System.out.println("测试人员先休息会...");condition2.await();}System.out.println("测试人员测试新功能");lock.unlock();} catch (InterruptedException e) {e.printStackTrace();}}});System.out.println("早上:");System.out.println("测试人员来上班了...");thread3.start();System.out.println("产品经理来上班了...");thread1.start();System.out.println("开发人员来上班了...");thread2.start();}
}

运行结果:

早上:
测试人员来上班了...
产品经理来上班了...
开发人员来上班了...
测试人员先休息会...
产品经理规划新需求
开发人员开发新需求功能
测试人员测试新功能

2.6、使用线程的CountDownLatch(倒计数)方法

CountDownLatch:位于java.util.concurrent包下,利用它可以实现类似计数器的功能。

应用场景:比如有一个任务C,它要等待其他任务A,B执行完毕之后才能执行,此时就可以利用CountDownLatch来实现这种功能了。

package com.线程;import java.util.concurrent.CountDownLatch;/*** @Auther: curry.zhang* @Date: 2019/9/23 17:05* @Description:*/
public class ThreadCountDownLatchDemo {/*** 用于判断线程一是否执行,倒计时设置为1,执行后减1*/private static CountDownLatch c1 = new CountDownLatch(1);/*** 用于判断线程二是否执行,倒计时设置为1,执行后减1*/private static CountDownLatch c2 = new CountDownLatch(1);public static void main(String[] args) {final Thread thread1 = new Thread(new Runnable() {@Overridepublic void run() {System.out.println("产品经理规划新需求");//对c1倒计时-1c1.countDown();}});final Thread thread2 = new Thread(new Runnable() {@Overridepublic void run() {try {//等待c1倒计时,计时为0则往下运行c1.await();System.out.println("开发人员开发新需求功能");//对c2倒计时-1c2.countDown();} catch (InterruptedException e) {e.printStackTrace();}}});Thread thread3 = new Thread(new Runnable() {@Overridepublic void run() {try {//等待c2倒计时,计时为0则往下运行c2.await();System.out.println("测试人员测试新功能");} catch (InterruptedException e) {e.printStackTrace();}}});System.out.println("早上:");System.out.println("测试人员来上班了...");thread3.start();System.out.println("产品经理来上班了...");thread1.start();System.out.println("开发人员来上班了...");thread2.start();}
}

运行结果:

早上:
测试人员来上班了...
产品经理来上班了...
开发人员来上班了...
产品经理规划新需求
开发人员开发新需求功能
测试人员测试新功能

2.7、使用CyclicBarrier(回环栅栏)实现线程按顺序运行

CyclicBarrier(回环栅栏):通过它可以实现让一组线程等待至某个状态之后再全部同时执行。叫做回环是因为当所有等待线程都被释放以后,CyclicBarrier可以被重用。我们暂且把这个状态就叫做barrier,当调用await()方法之后,线程就处于barrier了。

应用场景:公司组织春游,等待所有的员工到达集合地点才能出发,每个人到达后进入barrier状态。都到达后,唤起大家一起出发去旅行。

package com.线程;import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;/*** @Auther: curry.zhang* @Date: 2019/9/23 17:16* @Description: 使用CyclicBarrier(回环栅栏)实现线程按顺序运行*/
public class CyclicBarrierDemo {static CyclicBarrier barrier1 = new CyclicBarrier(2);static CyclicBarrier barrier2 = new CyclicBarrier(2);public static void main(String[] args) {final Thread thread1 = new Thread(new Runnable() {@Overridepublic void run() {try {System.out.println("产品经理规划新需求");//放开栅栏1barrier1.await();} catch (InterruptedException e) {e.printStackTrace();} catch (BrokenBarrierException e) {e.printStackTrace();}}});final Thread thread2 = new Thread(new Runnable() {@Overridepublic void run() {try {//放开栅栏1barrier1.await();System.out.println("开发人员开发新需求功能");//放开栅栏2barrier2.await();} catch (InterruptedException e) {e.printStackTrace();} catch (BrokenBarrierException e) {e.printStackTrace();}}});final Thread thread3 = new Thread(new Runnable() {@Overridepublic void run() {try {//放开栅栏2barrier2.await();System.out.println("测试人员测试新功能");} catch (InterruptedException e) {e.printStackTrace();} catch (BrokenBarrierException e) {e.printStackTrace();}}});System.out.println("早上:");System.out.println("测试人员来上班了...");thread3.start();System.out.println("产品经理来上班了...");thread1.start();System.out.println("开发人员来上班了...");thread2.start();}
}

运行结果:

早上:
测试人员来上班了...
产品经理来上班了...
开发人员来上班了...
产品经理规划新需求
开发人员开发新需求功能
测试人员测试新功能

2.8、使用Sephmore(信号量)实现线程按顺序运行

Sephmore(信号量):Semaphore是一个计数信号量,从概念上将,Semaphore包含一组许可证,如果有需要的话,每个acquire()方法都会阻塞,直到获取一个可用的许可证,每个release()方法都会释放持有许可证的线程,并且归还Semaphore一个可用的许可证。然而,实际上并没有真实的许可证对象供线程使用,Semaphore只是对可用的数量进行管理维护。

acquire():当前线程尝试去阻塞的获取1个许可证,此过程是阻塞的,当前线程获取了1个可用的许可证,则会停止等待,继续执行。

release():当前线程释放1个可用的许可证。

应用场景:Semaphore可以用来做流量分流,特别是对公共资源有限的场景,比如数据库连接。假设有这个的需求,读取几万个文件的数据到数据库中,由于文件读取是IO密集型任务,可以启动几十个线程并发读取,但是数据库连接数只有10个,这时就必须控制最多只有10个线程能够拿到数据库连接进行操作。这个时候,就可以使用Semaphore做流量控制。

package com.线程;import java.util.concurrent.Semaphore;/*** @Auther: curry.zhang* @Date: 2019/9/23 17:09* @Description: 使用Sephmore(信号量)实现线程按顺序运行*/
public class SemaphoreDemo {private static Semaphore semaphore1 = new Semaphore(1);private static Semaphore semaphore2 = new Semaphore(1);public static void main(String[] args) {final Thread thread1 = new Thread(new Runnable() {@Overridepublic void run() {System.out.println("产品经理规划新需求");semaphore1.release();}});final Thread thread2 = new Thread(new Runnable() {@Overridepublic void run() {try {semaphore1.acquire();System.out.println("开发人员开发新需求功能");semaphore2.release();} catch (InterruptedException e) {e.printStackTrace();}}});Thread thread3 = new Thread(new Runnable() {@Overridepublic void run() {try {semaphore2.acquire();thread2.join();semaphore2.release();System.out.println("测试人员测试新功能");} catch (InterruptedException e) {e.printStackTrace();}}});System.out.println("早上:");System.out.println("测试人员来上班了...");thread3.start();System.out.println("产品经理来上班了...");thread1.start();System.out.println("开发人员来上班了...");thread2.start();}
}

运行结果:

早上:
测试人员来上班了...
产品经理来上班了...
开发人员来上班了...
产品经理规划新需求
开发人员开发新需求功能
测试人员测试新功能

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/499803.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

mongodb数据库,批量插入性能测试记录

spring boot 框架下,操作mongodb数据库 maven:spring-data-mongodb:2.1.3.RELEASE mongo数据库用的是本地的mongo,所以环境不一样,可能结果不一样。但趋势应该是一样的。 测试保证每次批量插入时,库里的数据量都是一…

[转载] --- 数据库基本知识

里面的很多点,我之前都总结过,但是感觉这篇把这些都连起来了,总结的挺好,转载保存一下 【从入门到入土】令人脱发的数据库底层设计前言 说到数据库这个词,我只能用爱恨交加这个词来形容它。两年前在自己还单纯懵懂的时…

java中使用lua脚本

第一步: windows下,先下载安装lua(其他操作系统自行百度,我只说主要基本的流程) 下载地址 我选了lua-5.3.4_Win64_bin.zip为例 第二步: 解压到D盘根路径的lua文件夹中 配置环境变量,增加D:\l…

java中使用lua操作redis

java中使用lua脚本参见我的上一篇文章 lua基础 本篇简单说下java中使用lua操作redis的示例&#xff0c;如下&#xff1a; 先引入jedis <dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId><version>2.9.0</…

spring-boot发送邮件失败 AuthenticationFailedException: 535 Authentication Failed

发送邮件失败&#xff0c;平时一直是好的&#xff0c;突然有天开始失败了&#xff0c;最后是发现邮箱密码失效了。。。 有的邮箱&#xff0c;需要定期更改密码。

windows本地项目开机自启动设置

记录下&#xff0c;本地项目开机自启动 vue项目 新建vue.bat文件 echo off :: nodejs安装目录下的nodevars.bat set nodevars "D:\Program Files\nodejs\nodevars.bat" :: 切换到D盘 d: :: 移动到需要启动的目录 cd D:\Users\curry.zhang\IdeaProjects\data-chec…

互联网广告行业(01)------ 初识了解DSP、SSP、ADX

最近有幸接触到公司的一个实时竞价系统&#xff0c;也算是公司的核心系统之一了&#xff0c;增加了很多新的知识&#xff0c;可能有点乱&#xff0c;先总结一波&#xff1a; 广告行业&#xff0c;先介绍概念 广告主&#xff1a;需要打广告的站点&#xff0c;一般就是卖东西的…

互联网广告行业(02)------OpenRTB(实时竞价)规范解读

RTB&#xff1a;(Real Time Bidding实时竞价)&#xff0c;RTB是一种广告交易的方式 OpenRTB&#xff1a;简单理解就是一个行业规范&#xff0c;是一个为了促进RTB方式广告的标准&#xff0c;有对应的api文档&#xff0c;大家都按照这个规范去传参数&#xff0c;那么发送方和接收…

[go]---从java到go(01)---基础与入门上手

为什么用go&#xff0c;就是为了快速响应并且高并发。 一样的逻辑&#xff0c;用java也能实现&#xff0c;但用go可能就比java快点。 如果你很熟练java了&#xff0c;那么学习go就会很快。 go的社区环境相比java没那么大&#xff0c;但一般问题都足够了。 go是谷歌出品&#xf…

[go]---从java到go(02)---一个简单的handler模式的实现

类似于责任链模式吧&#xff0c;不同类实现相同的入参&#xff0c;执行不同的操作&#xff0c;一个执行完再确定要不要执行下一个。 用go实现&#xff1a; 1.定义一个接口 后面所有的handler都要实现这个接口的handler方法 type IHandler interface {/**true 表示通过 false…

[数据库] --- clickhouse

clickhouse是一个列式数据库&#xff08;系统&#xff09;。 官方文档 官网比较全&#xff0c;但也可以说比较杂&#xff0c;下面就是我个人的一些总结&#xff0c;以及在实际工作中的应用场景。 1.clickhouse适用场景 clickhouse主要适合那种大量数据做分析的场景。 一般数据…

错误记录:expected single matching bean but found 2

springboot项目&#xff0c;之前有mysql数据源&#xff0c;现在又新增了clickhouse数据源&#xff0c;于是 新增了一个clickhouseDatasource的配置bean&#xff0c;如下&#xff1a; Beanpublic DataSource dataSource() throws PropertyVetoException {HikariConfig config …

消息队列(5):RocketMQ

介绍 RocketMQ是一款成熟的分布式消息中间件。 由阿里2012年开源&#xff0c;2017年成为Apache顶级项目。 源码是java写的。 高性能&#xff0c;低延迟&#xff0c;高可靠。历经多次双十一大促&#xff0c;整体很稳定。 RocketMQ对比其他mq的优势 对比kafka和Rabbitmq&#…

[错误记录] --- clickhouse报错Decimal value is too small

java操作clickhouse数据库&#xff0c;执行insert的时候&#xff0c;报错&#xff1a; Exception in thread "main" ru.yandex.clickhouse.except.ClickHouseException: ClickHouse exception, code: 69, host: xx.xx.xx.xxx, port: xxxx; Code: 69, e.displayText(…

[错误记录] --- rocketmq批量消费设置参数的问题

rocketmq想支持批量消费&#xff0c;于是便设置以下参数&#xff1a; consumer.setConsumeMessageBatchMaxSize(1000);这样是正确的&#xff0c;但由于业务要求&#xff0c;还想再设置大点&#xff0c;于是设置成这样&#xff1a; consumer.setConsumeMessageBatchMaxSize(10…

rocketmq批量消费

rocketmq默认就是可以批量消费的&#xff0c;但需要设置多个参数一起配合。 我们只需要知道他是怎么消费的&#xff0c;就可以很精准的设置他的批量消费参数。 我们看看DefaultMQPushConsumer源码中的这几个参数&#xff1a; /*** 消费消息线程&#xff0c;最小数目*/private …

阿波罗配置中心(apollo)的个人看法

阿波罗应该是近几年比较火的一个分布式配置中心了&#xff0c;说说我个人的理解&#xff0c;希望对一些人有用吧。 首先从使用者的角度想 我们怎么用配置中心的&#xff1f; 1.得有个页面&#xff0c;能有权限管理&#xff0c;能有创建配置key-value。 在阿波罗中&#xff…

架构师成长之路

一个架构师要掌握的最基本的数学知识 知识点备注log三角函数二项式定理多项式合并极限幂函数泰勒级数傅里叶级数概率

消息队列(4):Kafka

介绍 kafka是一个支持分布式的消息系统&#xff0c;基于发布/订阅模式。 kafka由LinkedIn公司开发&#xff0c;2010年成为Apache顶级项目。 源码是由java写的。 基本概念 1、Broker kafka集群中的每台机器&#xff0c;都叫一个broker. 2、Topic&#xff08;主题&#xff0…

clickhouse的ReplacingMergeTree引擎实战

学习ReplacingMergeTree引擎&#xff0c;首先你得了解clickhouse的MergeTree引擎&#xff0c;因为ReplacingMergeTree引擎是MergeTree引擎的一个扩展版引擎&#xff0c;他拥有和MergeTree一样的功能&#xff0c;同时新增了一个删除相同主键数据的功能。 我们知道&#xff0c;cl…