관련 지식: 실행자(스레드 풀), CountDownLatch(잠금)
장점: 간결한 코드, 읽기 쉬움, 안정적인 성능;
단점: Executors가 생성한 스레드 풀은 공개됩니다. 이 루프 멀티스레딩 방법을 여러 곳에서 사용하면 스레드 풀 리소스가 강탈되고 실행 속도도 저하됩니다.
import java.util.*; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class test{ /** 固定的线程池(当前线程池大小为5) */ private static final ExecutorService executor = Executors.newFixedThreadPool(5); public static void main(String[] args) throws Exception { /** * 两个要点: * 1.用Executors实现固定大小的线程池,从而达到控制硬件资源消耗的目的。 * 2.用CountDownLatch(闭锁),来确保循环内的多线程都执行完成后,再执行后续代码 */ // 初始化数据 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); } // 初始化计时器 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(); // 模拟运行耗时 Thread.sleep(500); System.out.println(name+":执行到"+object.get("index")); object.put("status","已经执行过"); } catch (InterruptedException e) { e.printStackTrace(); } // 闭锁-1 cdl.countDown(); } }); } // 调用闭锁的await()方法,该线程会被挂起,它会等待直到count值为0才继续执行 // 这样我们就能确保上面多线程都执行完了才走后续代码 cdl.await(); //关闭线程池 executor.shutdown(); System.out.println("====== 线程结束 ====="); // 校验多线程正确性 for(Map<String,Object> object:list){ System.out.println(object.get("index") + ":" + object.get("status")); } } }
각 서비스는 비즈니스를 담당합니다. 여러 번 반복되는 작업을 수행하려면 for 루프를 사용해야 합니다. 예를 들어 저장된 ID 모음을 탐색하여 각 ID에 대해 무언가를 생성합니다.
그러나 단일 스레드를 사용하여 작업을 실행하면 마지막 작업이 실행될 때까지 기다리는 데 많은 시간을 낭비하게 되며, 실행 중에 오류가 보고되면 작업 실행이 중지되는데 이는 분명히 우리의 요구 사항을 충족하지 않습니다.
이 경우 for 루프에서 멀티스레딩을 사용하세요.
아아아아위 내용은 Java for 루프의 멀티스레딩 문제를 해결하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!