Question

java问题 有一个list有1W条数据， 现在我想用多线程不重复的读取list中的数据，要怎么写？

例如：
线程N读list[0]
线程N读list[1]
线程N读list[2]
...
线程N读list[9999]
线程N读list[10000]

Answer 1

把读取的方法写成同步方法。然后起很多线程调用这个读的方法去读该list。

Answer 2

import java.util.*;
public class Demo{
public static void main(String[] rags){
MyThread mt= new MyThread();
for(int i=0;i<mt.list.size();i++){
new Thread(mt).start();
}

}
}
class MyThread implements Runnable{
List<String> list = new ArrayList<String>();
list.add("a");
list.add("b");
int init = 0;
public void run(){
System.out.println(list.get(init));
}
}

追问

list.add("a");
list.add("b");
你好，这句代码是什么意思？为什么还叫add

追答

我只是随便做一个list，你有现成的list，直接调用就好了，这里写错了，应该是：
public void run(){
System.out.println(list.get(init++));
}

追问

你有QQ吗，帮我解决下，给你加分好不好 QQ 二七二九九七一六

Answer 3

@Slf4j
public class FixedThreadPool {

/** 请求总数**/
private static int clientTotal = 100;

public static AtomicInteger atomicInteger = new AtomicInteger(0);

public static void main(String[] args) throws Exception {
ExecutorService executorService = Executors.newFixedThreadPool(10);
final CountDownLatch countDownLatch = new CountDownLatch(clientTotal);
for (int i = 0; i < clientTotal; i++) { //这里clientTotal你换成你的list的size
atomicInteger.incrementAndGet();
while (atomicInteger.get() > 4){
Thread.sleep(10);
}
executorService.execute(() -> {
consoleLog();
countDownLatch.countDown();
atomicInteger.decrementAndGet();
});

}
countDownLatch.await();
executorService.shutdown();
log.info("全部执行完毕");
}
private static void consoleLog(){
try {
log.info("hello");
Thread.sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
}

}
}