欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Java多線程處理List問題

 更新時間:2023年09月21日 16:25:44   作者:JonTang  
這篇文章主要介紹了Java多線程處理List問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教

Java多線程處理List

項目場景

調(diào)用第三方提供的接口去獲取 List 中用戶的組信息。

問題描述

需要拿用戶的 id 去調(diào)用第三方接口,成功調(diào)用一次需要 0.3s 左右,當有 1000 個用戶時,就需要花費 0.3 * 1000s = 5min,頁面就會一直加載那么久。

之前是通過 for 循環(huán) list 去調(diào)用接口的,

代碼如下:

// 當 list 長度為 1000時,則需要循環(huán) 1000次
for(User user : list) {
    loadUserGroups(user);
}

解決方案

通過多線程的方式去處理,話不多說直接上代碼:

// 定義一個線程池
private static final ExecutorService loadUserGroupsExecutor = Executors.newFixedThreadPool(20);
public Map<String, List<UserGroup>> loadAllUserGroups() {
        Map<String, List<UserGroup>> userGroups = new ConcurrentHashMap<>();
        List<User> users = listUsers();
        int size = users.size();       
        long startTime = System.currentTimeMillis();        
        if (size > 200) {            
            List<List<User>> partition = Lists.partition(users, 200);            
            List<CompletableFuture> results = new ArrayList<>();            
            for (List<User> subList : partition) {                
                CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {                    
                loadUserGroups(userGroups, subList);                    
                return "";                
                }, loadUserGroupsExecutor);                
            	    results.add(future);            
                }            
            CompletableFuture.allOf(results.toArray(results.toArray(new CompletableFuture[partition.size()]))).join();        
        } else {            
        	loadUserGroups(userGroups, users);        
        }
    	log.info("loadAllUserGroups cost {}", System.currentTimeMillis() - startTime);        
     return userGroups;
}

Java多線程分段處理List集合

場景:

大數(shù)據(jù)List集合,需要對List集合中的數(shù)據(jù)同標準庫中數(shù)據(jù)進行對比,生成新增,更新,取消數(shù)據(jù) 

解決方案

  • List集合分段
  • 動態(tài)創(chuàng)建線程池newFixedThreadPool
  • 將對比操作在多線程中實現(xiàn)
public static void main(String[] args) throws Exception {
?? ?// 開始時間
?? ?long start = System.currentTimeMillis();
?? ?List<String> list = new ArrayList<String>();
?? ?for (int i = 1; i <= 3000; i++) {
?? ??? ?list.add(i + "");
?? ?}
? ? /*動態(tài)線程數(shù)方式*/
?? ?// 每500條數(shù)據(jù)開啟一條線程
?? ?int threadSize = 500;
?? ?// 總數(shù)據(jù)條數(shù)
?? ?int dataSize = list.size();
?? ?// 線程數(shù),動態(tài)生成
?? ?int threadNum = dataSize / threadSize + 1;
? ? /*固定線程數(shù)方式
?? ? ? ?// 線程數(shù)
?? ? ? ?int threadNum = 6;
?? ? ? ?// 總數(shù)據(jù)條數(shù)
?? ? ? ?int dataSize = list.size();
?? ? ? ?// 每一條線程處理多少條數(shù)據(jù)
?? ? ? ?int threadSize = dataSize / (threadNum - 1);
? ? */
?? ?// 定義標記,過濾threadNum為整數(shù)
?? ?boolean special = dataSize % threadSize == 0;
?? ?// 創(chuàng)建一個線程池
?? ?ExecutorService exec = Executors.newFixedThreadPool(threadNum);
?? ?// 定義一個任務集合
?? ?List<Callable<Integer>> tasks = new ArrayList<Callable<Integer>>();
?? ?Callable<Integer> task = null;
?? ?List<String> cutList = null;
?? ?// 確定每條線程的數(shù)據(jù)
?? ?for (int i = 0; i < threadNum; i++) {
?? ??? ?if (i == threadNum - 1) {
?? ??? ??? ?if (special) {
?? ??? ??? ??? ?break;
?? ??? ??? ?}
?? ??? ??? ?cutList = list.subList(threadSize * i, dataSize);
?? ??? ?} else {
?? ??? ??? ?cutList = list.subList(threadSize * i, threadSize * (i + 1));
?? ??? ?}
?? ??? ?final List<String> listStr = cutList;
?? ??? ?task = new Callable<Integer>() {
?? ??? ??? ?@Override
?? ??? ??? ?public Integer call() throws Exception {
?? ??? ??? ??? ?//業(yè)務邏輯,循環(huán)處理分段后的list
?? ??? ??? ??? ?System.out.println(Thread.currentThread().getName() + "線程:" + listStr);
?? ??? ??? ??? ?//......
?? ??? ??? ??? ?return 1;
?? ??? ??? ?}
?? ??? ?};
?? ??? ?// 這里提交的任務容器列表和返回的Future列表存在順序對應的關系
?? ??? ?tasks.add(task);
?? ?}
?? ?exec.invokeAll(tasks);
?? ?// 關閉線程池
?? ?exec.shutdown();
?? ?System.out.println("線程任務執(zhí)行結束");
?? ?System.out.println("執(zhí)行任務消耗了 :" + (System.currentTimeMillis() - start) + "毫秒");
}

總結

以上為個人經(jīng)驗,希望能給大家一個參考,也希望大家多多支持腳本之家。

相關文章

  • Spring Cloud Alibaba使用Sentinel實現(xiàn)接口限流

    Spring Cloud Alibaba使用Sentinel實現(xiàn)接口限流

    這篇文章主要介紹了Spring Cloud Alibaba使用Sentinel實現(xiàn)接口限流,本文詳細的介紹了Sentinel組件的用法以及接口限流,感興趣的可以了解一下
    2019-04-04
  • Flink ExecutionGraph生成源碼解析

    Flink ExecutionGraph生成源碼解析

    這篇文章主要為大家介紹了Flink ExecutionGraph生成源碼解析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2022-12-12
  • Java中BigInteger用法小結

    Java中BigInteger用法小結

    這篇文章主要介紹了Java中BigInteger用法的詳解,在這里,我們詳細描述下BigInteger的用法,在使用之前,我們需要導入java.math.*包,本文通過實例代碼相結合給大家詳細講解,需要的朋友可以參考下
    2023-03-03
  • SpringBoot利用Validation包實現(xiàn)高效參數(shù)校驗

    SpringBoot利用Validation包實現(xiàn)高效參數(shù)校驗

    如果不進行校驗就直接使用這些數(shù)據(jù),可能會導致各種問題,那么SpringBoot如何利用Validation包實現(xiàn)高效參數(shù)校驗呢,下面讓我們一起來探討這個重要的話題吧
    2025-04-04
  • Java利用AQS實現(xiàn)自定義鎖

    Java利用AQS實現(xiàn)自定義鎖

    本文主要介紹了Java利用AQS實現(xiàn)自定義鎖,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧
    2022-07-07
  • Java中的?HTTP?協(xié)議原理詳解

    Java中的?HTTP?協(xié)議原理詳解

    這篇文章主要介紹了Java中的?HTTP?協(xié)議原理詳解,HTTP超文本傳輸協(xié)議,下文簡稱?HTTP,它的作用是用于實現(xiàn)服務器端和客戶端的數(shù)據(jù)傳輸?shù)?/div> 2022-07-07
  • Springboot啟動原理和自動配置原理解析

    Springboot啟動原理和自動配置原理解析

    這篇文章主要介紹了Springboot啟動原理和自動配置原理解析,本文通過實例代碼給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2023-04-04
  • springboot全局異常處理方式@ControllerAdvice和@ExceptionHandler

    springboot全局異常處理方式@ControllerAdvice和@ExceptionHandler

    文章總結了個人在處理全局異常處理時的經(jīng)驗,包括使用`StatusEnum`來定義狀態(tài)碼,旨在為讀者提供參考,并鼓勵大家支持腳本之家
    2024-11-11
  • 騰訊云部署javaWeb項目的實現(xiàn)步驟

    騰訊云部署javaWeb項目的實現(xiàn)步驟

    本文主要介紹了騰訊云部署javaWeb項目的實現(xiàn)步驟,文中通過示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2021-08-08
  • Java zookeeper服務的使用詳解

    Java zookeeper服務的使用詳解

    ZooKeeper是一個分布式的,開放源碼的分布式應用程序協(xié)調(diào)服務,是Google的Chubby一個開源的實現(xiàn),是Hadoop和Hbase的重要組件。它是一個為分布式應用提供一致性服務的軟件,提供的功能包括:配置維護、域名服務、分布式同步、組服務等
    2022-08-08

最新評論