springboot+多线程简单实现

alexnevsky 发布于2019-07-24 10:52 / 2509人阅读

搭建springboot环境
创建ThreadConfig

/**
 * 线程
 *
 * @author zhoumin
 * @create 2018-09-18 13:58
 */
@Configuration
@EnableAsync
public class ThreadConfig implements AsyncConfigurer{
    @Override
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(8);
        executor.setMaxPoolSize(1000);
        executor.setQueueCapacity(500);
        executor.setKeepAliveSeconds(30000);
        executor.initialize();
        return executor;
    }

    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        return null;
    }
}

创建service和接口

void test(int i);

service实现类

@Override
@Async
public void test(int i) {
  System.out.println("线程" + Thread.currentThread().getName() + " 执行异步任务：" + i);
}

测试：

@RunWith(SpringRunner.class)
@SpringBootTest
public class BaseTest {

}

/**
 * @author zhoumin
 * @create 2018-09-18 14:12
 */
public class ThreadTest extends  BaseTest{
    @Autowired
    private DeviceStatisticsTaskService deviceStatisticsTaskService;

    @org.junit.Test
    public void threadTest() {
        for (int i = 0; i < 5000; i++) {

            deviceStatisticsTaskService.test(i);
        }
    }
}

云服务器 GPU云服务器简单多线程服务器编码实现多线程多线程实现多线程怎么实现

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/35996.html

Springboot对多线程的支持详解

摘要：对多线程的支持详解这两天看阿里的开发手册，到多线程的时候说永远不要用这种方式来使用多线程。在使用线程池的大多数情况下都是异步非阻塞的。二配置类配置类代码如下下午解读利用来开启对于异步任务的支持配置类实现接口，返回一个线程池对象。 Springboot对多线程的支持详解这两天看阿里的JAVA开发手册，到多线程的时候说永远不要用 new Thread()这种方式来使用多线程。确实是这样的...

adie 2019-08-19 10:48 评论0 收藏0
springboot配置线程池使用多线程插入数据

摘要：最开始是使用的正常的普通方式去写入，但是量太大了，所以就尝试使用多线程来写入。下面我们就来介绍一下怎么使用多线程进行导入。配置线程池我们需要创建一个类来设置线程池的各种配置。它可以使主线程一直等到所有的子线程执行完之后再执行。前言：最近在工作中需要将一大批数据导入到数据库中，因为种种原因这些数据不能使用同步数据的方式来进行复制，而是提供了一批文本，文本里面有很多行url地址，需要的...

wenshi11019 2019-08-19 11:08 评论0 收藏0
SpringBoot RabbitMQ 整合使用

摘要：可以在地址看到如何使用讲解下上面命令行表示控制台端口号，可以在浏览器中通过控制台来执行的相关操作。同时从控制台可以看到发送的速率多线程测试性能开了个线程，每个线程发送条消息。 showImg(http://ww2.sinaimg.cn/large/006tNc79ly1g5jjb62t88j30u00gwdi2.jpg); 前提上次写了篇文章，《SpringBoot Kafka 整合...

yuanxin 2019-08-19 10:16 评论0 收藏0