java.util.concurrent.ExecutionException错误信息，这里给出解决方案，大家根据具体要求更改。 ? 1 2 3 4 5 6 7 继续阅读

目录 一、继承Thread类  二、实现runnabe接口  三、实现Callable接口  四、匿名内部类 五、线程池的实现(java.util.concurrent.Executor接口)  六、Java的调度方法  1、线程的优先级 2、线程的生命周期 一、继承Thread类 定义子类继承Thread类。子类中重写Thread类中的run方法。创建Thread子类对象，即创建了线程对象。调用线程对象start方法：启动线程&#xff0 继续阅读

上一讲【RocketMQ】消息的拉取 消息消费 当RocketMQ进行消息消费的时候，是通过ConsumeMessageConcurrentlyService的submitConsumeRequest方法，将消息提交到线程池中进行消费，具体的处理逻辑如下： 如果本次消息的个数小于等于批量消费的大小consumeBatchSize，构建消费请求ConsumeRequest，直接提交到线程池中进行消费即可如果本 继续阅读