搭建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); } } }
文章版權歸作者所有,未經允許請勿轉載,若此文章存在違規行為,您可以聯系管理員刪除。
轉載請注明本文地址:http://m.specialneedsforspecialkids.com/yun/35996.html
摘要:對多線程的支持詳解這兩天看阿里的開發手冊,到多線程的時候說永遠不要用這種方式來使用多線程。在使用線程池的大多數情況下都是異步非阻塞的。二配置類配置類代碼如下下午解讀利用來開啟對于異步任務的支持配置類實現接口,返回一個線程池對象。 Springboot對多線程的支持詳解 這兩天看阿里的JAVA開發手冊,到多線程的時候說永遠不要用 new Thread()這種方式來使用多線程。確實是這樣的...
摘要:最開始是使用的正常的普通方式去寫入,但是量太大了,所以就嘗試使用多線程來寫入。下面我們就來介紹一下怎么使用多線程進行導入。配置線程池我們需要創建一個類來設置線程池的各種配置。它可以使主線程一直等到所有的子線程執行完之后再執行。 前言: 最近在工作中需要將一大批數據導入到數據庫中,因為種種原因這些數據不能使用同步數據的方式來進行復制,而是提供了一批文本,文本里面有很多行url地址,需要的...
摘要:可以在地址看到如何使用講解下上面命令行表示控制臺端口號,可以在瀏覽器中通過控制臺來執行的相關操作。同時從控制臺可以看到發送的速率多線程測試性能開了個線程,每個線程發送條消息。 showImg(http://ww2.sinaimg.cn/large/006tNc79ly1g5jjb62t88j30u00gwdi2.jpg); 前提 上次寫了篇文章,《SpringBoot Kafka 整合...
閱讀 637·2021-11-22 15:32
閱讀 2724·2021-11-19 09:40
閱讀 2319·2021-11-17 09:33
閱讀 1276·2021-11-15 11:36
閱讀 1873·2021-10-11 10:59
閱讀 1485·2019-08-29 16:41
閱讀 1787·2019-08-29 13:45
閱讀 2155·2019-08-26 13:36