java?for循環(huán)內(nèi)執(zhí)行多線程問題

更新時(shí)間：2023年03月10日 08:32:55 作者：熙街丶一人

這篇文章主要介紹了java?for循環(huán)內(nèi)執(zhí)行多線程問題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

java用多線程來加快循環(huán)效率

線程池搭配閉鎖

涉及知識(shí)：Executors（線程池）、CountDownLatch（閉鎖）

優(yōu)點(diǎn)：代碼簡(jiǎn)潔，方便閱讀，性能穩(wěn)定；

缺點(diǎn)：Executors創(chuàng)建的線程池是公用的，如果多個(gè)地方使用這種循環(huán)多線程的方式，就會(huì)搶奪線程池資源，這樣運(yùn)行速度也會(huì)降低；

import java.util.*;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
 
public class test{
 
    /** 固定的線程池（當(dāng)前線程池大小為5） */
    private static final ExecutorService executor = Executors.newFixedThreadPool(5);
    
    public static void main(String[] args) throws Exception {
        /**
         *  兩個(gè)要點(diǎn)：
         *  1.用Executors實(shí)現(xiàn)固定大小的線程池，從而達(dá)到控制硬件資源消耗的目的。
         *  2.用CountDownLatch（閉鎖），來確保循環(huán)內(nèi)的多線程都執(zhí)行完成后，再執(zhí)行后續(xù)代碼
         */
        
        // 初始化數(shù)據(jù)
        List<Map<String,Object>> list = new ArrayList<>();
        for(int i=0;i<50;i++){
            Map<String,Object> object = new HashMap<>();
            object.put("index",i);
            list.add(object);
        }
 
        // 初始化計(jì)時(shí)器
        CountDownLatch cdl = new CountDownLatch(list.size());
        System.out.println("====== 線程開始 =====");
 
        // 遍歷
        for(Map<String,Object> object:list){
            // 開啟線程
            executor.submit(new Runnable() {
                @Override
                public void run() {
                    try {
                        Thread t = Thread.currentThread();
                        String name = t.getName();
                        // 模擬運(yùn)行耗時(shí)
                        Thread.sleep(500);
                        System.out.println(name+"：執(zhí)行到"+object.get("index"));
                        object.put("status","已經(jīng)執(zhí)行過");
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    // 閉鎖-1
                    cdl.countDown();
                }
            });
        }
        
        // 調(diào)用閉鎖的await()方法，該線程會(huì)被掛起，它會(huì)等待直到count值為0才繼續(xù)執(zhí)行
        // 這樣我們就能確保上面多線程都執(zhí)行完了才走后續(xù)代碼
        cdl.await();
        
        //關(guān)閉線程池
        executor.shutdown();
        System.out.println("====== 線程結(jié)束 =====");
 
        // 校驗(yàn)多線程正確性
        for(Map<String,Object> object:list){
            System.out.println(object.get("index") + ":" + object.get("status"));
        }
 
    }
}

for循環(huán)中使用多線程

每個(gè)service負(fù)責(zé)一個(gè)業(yè)務(wù)，多次進(jìn)行重復(fù)業(yè)務(wù)就要使用到for循環(huán)，例如對(duì)某個(gè)存儲(chǔ)id的集合遍歷，并為每個(gè)id創(chuàng)建一些東西。

但是使用單線程執(zhí)行任務(wù)會(huì)因?yàn)榈却洗稳蝿?wù)執(zhí)行完而浪費(fèi)很多時(shí)間，并且一旦某次執(zhí)行報(bào)錯(cuò)，任務(wù)就會(huì)停止執(zhí)行，明顯不符合我們的要求。

這種情況就在for循環(huán)中使用多線程。

import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
 
public class Test {
 
    /**
     * ThreadPool 自定義一個(gè)線程池
     */
    private static final ThreadPoolExecutor EXECUTOR = new ThreadPoolExecutor(2, 4, 60L, TimeUnit.SECONDS, new LinkedBlockingQueue<>(60000));
 
    public static void main(String[] args) {
        //自己的數(shù)組或集合,這里不再進(jìn)行填充
        String[] ids = new String[10]
        
        for (String id : ids) {
            EXECUTOR.execute(new Runnable() {
                @Override
                public void run() {
                    try {
                        //需要執(zhí)行的業(yè)務(wù)邏輯
                        System.out.println("業(yè)務(wù)邏輯正在執(zhí)行");
                    } catch (Exception e) {
                        //todo
                    }
                }
            });
        }
    }
 
}