学习ForkJoin
- 一、普通解决多线程方式
- 1、案例一
- 2、效果图
- 二、ForkJoin
一、普通解决多线程方式
1、案例一
大数据量的List问题处理,多线程分批处理,需要解决的问题:
- 下标越界。
- 线程安全。
- 数据丢失。
private static ThreadPoolExecutor threadPool = new ThreadPoolExecutor(
5,
10 * 3,
60 * 60,
TimeUnit.SECONDS,
new LinkedBlockingQueue<Runnable>(500)
);
@Test
void test1() {
//不安全
List<String> result1 = new ArrayList<>();
//安全(效率低)
Vector<String> result2 = new Vector<>();
//安全(效率中)
List<String> result3 = new CopyOnWriteArrayList<>();
//安全(效率高)
List result4 = Collections.synchronizedList(new ArrayList());
//根据参数开启线程
CountDownLatch countDownLatch = new CountDownLatch(5);
for (int i = 0; i < 5; i++) {
threadPool.execute(new Thread(new Runnable() {
@SneakyThrows
@Override
public void run() {
for (int i = 0; i < 100; i++) {
result1.add("listi" + i);
result2.add("listi" + i);
result3.add("listi" + i);
result4.add("listi" + i);
}
Thread.sleep(3000);
//等待线程数减一
countDownLatch.countDown();
}
}));
}
try {
// 主线程等待
countDownLatch.await();
System.err.println("----------");
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(result1.size());
System.out.println(result2.size());
System.out.println(result3.size());
System.out.println(result4.size());
}
2、效果图
二、ForkJoin
动态规范:和分而治之不同的是,每个小任务之间互相联系。
工作密取:分而治之分割了每个任务之后,某个线程提前完成了任务,就会去其他线程偷取任务来完成,加快执行效率。同时,第一个分配的线程是从队列中的头部拿任务,当完成任务的线程去其他队列拿任务的时候是从尾部拿任务,所以这样就避免了竞争。
注意:ForkJoinPool的invoke方法是同步阻塞的,excute方法是异步的。
- 稻谷飘香:秋天稻谷成熟了,飘着阵阵香味。
- 人是不能太闲的,闲久了,努力一下就以为自己是拼命。
- 一个人至少拥有一个梦想,有一个理由去坚强。
- 人的潜能是一座无法估量的丰富的矿藏,只等着我们去挖掘。
- 保持前进,丝毫别在乎别人想什么说什么,做你自己必须做的,为自己。
- 看似是在消磨时间,实际是在消磨自己。
- 不努力挣钱买房子打算租一辈子房子吗?你现在年轻有人租给你,可是你老了谁敢租给你?
- 每一奋发尽力的背地,必有加倍的犒赏。
- 再多一点努力,就多一点成功。
- 人的潜能是一座无法估量的丰富的矿藏,只等着我们去挖掘。