建设微信商城网站,做网站编辑需要看什么书,濮阳网络化,做网站以后的趋势知乎首先确定线程数量。如果数据集合的大小小于50#xff0c;就只使用一个线程#xff1b;否则使用5个线程。计算每个线程平均处理的数据数量sizePerThread以及余数remainder。在划分数据子集合时#xff0c;对于每个线程的处理范围进行计算。如果有余数#xff0c;就将余数依次…首先确定线程数量。如果数据集合的大小小于50就只使用一个线程否则使用5个线程。计算每个线程平均处理的数据数量sizePerThread以及余数remainder。在划分数据子集合时对于每个线程的处理范围进行计算。如果有余数就将余数依次分配到前面的线程中这里是简单地让前面的线程多处理一个数据。最后一个线程的结束索引直接设置为数据集合的大小确保能处理完所有数据。每个线程在处理完自己的数据后调用latch.countDown()主线程通过latch.await()等待所有线程完成任务后再继续执行后续操作。CopyOnWriteArrayList它是线程安全的适用于读多写少的场景
package com.syplatform;import static org.junit.Assert.assertTrue;import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.CountDownLatch;import org.junit.Test;/*** Unit test for simple App.*/
public class AppTest {/*** Rigorous Test :-)*/Testpublic void shouldAnswerWithTrue() throws InterruptedException {CopyOnWriteArrayListInteger finalList new CopyOnWriteArrayList();ListInteger dataList new ArrayList();for (int i 1; i 101; i) {dataList.add(i);}// 根据数据量决定线程数量int numThreads dataList.size() 50 ? 1 : 5;int size dataList.size();int partSize size / numThreads;// 处理不能整除的情况将剩余的任务分配到前面的线程中int remainder size % numThreads;int startIndex 0;CountDownLatch latch new CountDownLatch(numThreads);for (int i 0; i numThreads; i) {int endIndex startIndex partSize (i remainder ? 1 : 0);ListInteger subList dataList.subList(startIndex, endIndex);startIndex endIndex;Thread thread new Thread(() - {for (Integer num : subList) {finalList.add(num);System.out.println(Thread.currentThread().getName() processing num);}latch.countDown();});thread.start();}latch.await();System.out.println(All threads have finished processing.);assertTrue(finalList.size() 101);}
}
