首页 > 其他分享 >Future集合会等线程池执行完才开始遍历吗?

Future集合会等线程池执行完才开始遍历吗?

时间:2024-06-13 15:11:25浏览次数:17  
标签:遍历 iterator 完才 List Future 线程 futureList 执行

先说结论:Future集合并不是等线程池执行完才开始遍历,而是线程池内的线程执行完一条Future集合就立即遍历一条


在使用线程池的业务场景下,我们经常需要获取线程执行的返回值,此时我们需要Callable对象当做线程池参数并用List<Future>接收,然后遍历List<Future>获取我们想要的值。

但是,如果List<Future>是等线程池中所有的线程执行完后才开始遍历,就意味着List集合可能会非常大,进而导致内存溢出程序崩溃。所以我们就来验证一下List<Future>是会等待线程池执行完毕开始遍历还是只要线程执行完一条就遍历一条

示例:

ThreadPoolExecutor executor = new ThreadPoolExecutor(1, 5, 60L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>());
List<Future<Integer>> futureList = new ArrayList<>();
for (int i = 0; i < 5; i++) {
    int finalI = i;
    Future<Integer> future = executor.submit(() -> {
        Thread.sleep(1000L);
        System.out.println(Thread.currentThread().getName() + " " + finalI);
        return finalI;
    });
    futureList.add(future);
}
System.out.println("futureList.size() = "+futureList.size());
Iterator<Future<Integer>> iterator = futureList.iterator();
while (iterator.hasNext()) {
    Integer i = iterator.next().get();
    iterator.remove();
    System.out.println("执行后 " + i);
    //业务代码......
}

执行结果:

由此足以证明List<Future>集合不会等待线程池执行完才开始遍历,只要我们在遍历后把元素删除就能一定程度避免List<Future>过大导致内存溢出。

注意这里说的是一定程度,并不能完全避免,这取决于“业务代码”的执行时长,如果上面线程池都执行完了,下面一个业务都没处理完,同样会导致List<Future>占用很多内存,所以业务代码尽量放到上面的线程池里面。

当然如果能确定List<Future>不会很大导致内存溢出放到下面遍历自然更加优美,还请根据实际业务情况抉择。

标签:遍历,iterator,完才,List,Future,线程,futureList,执行
From: https://www.cnblogs.com/GilbertDu/p/18245912

相关文章

  • C#中使用AutoResetEvent或者ManualResetEvent做线程管理
    1.Task/thread/sync/async..await/WhenAll相关基础知识参见此处链接2.什么是AutoResetEvent和ManualResetEvent事件他们都是C#中System.Threading下面的类。用于在多个线程之间进行事件通知和管理。他们的管理方法主要是三个:Reset():关闭WaitOne():阻挡Set():启动AutoR......
  • 一看就懂,小白也会配置线程池了;SpringBoot简单配置线程池,
    线程池是Java实现并发的第一步,以下在SpringBoot中配置线程池的步骤,简单易学,小白也可以配置。编写一个类,实例化线程池的数学参数:包括核心线程数、最大线程数、允许挂载时间、阻塞队列数: //线程池的几个整数的参数,用到配置文件application.yml和dev配合一起配置;//在applicat......
  • 探索鸿蒙系统中的OffscreenCanvas并发线程绘制问题
    引言作为一名热衷于鸿蒙系统开发的工程师,我近期遇到了一个关于OffscreenCanvas组件在并发线程中绘制时崩溃的问题。这个问题不仅挑战了我的技术理解,也促使我深入探索鸿蒙系统的内部机制。在这篇文章中,我将分享我的发现和解决问题的过程。问题描述在开发过程中,我尝试使用O......
  • Qt - 多线程之线程的开始暂停恢复停止
    示例1在Qt中,可以使用QThread的线程控制功能来暂停和恢复一个线程。这里是一个简单的例子:#include<QThread>#include<QDebug>classWorkerThread:publicQThread{voidrun()override{qDebug()<<"Threadisrunning";//执行一些任务......
  • 【java基础】线程池的状态流转
    前言:首先要知道什么是线程池?池化:数据库连接池,线程池,字符串常量池线程是用来执行任务的,如果不用线程池,那么线程每次使用前创建,使用后释放,资源利用率低。所以说用线程池提高了线程对象利用率。所以可以用线程池完成,先创建好那么多个线程对象在那等着,类比银行客户等待窗口办理......
  • 【java基础】java线程的四种创建方式
    1.继承Thread类 2.实现Runnable接口 因为Runnable接口就是支持函数式编程的接口,可以这么玩 3.实现Callable接口,用FutureTask<T>获取返回值。FutureTask还是继承的Runnable接口   4.创建线程池Executors。由于Executors提供的等待队列LinkedBlockingQ是无界......
  • 线程池 (重点)概述&7大参数理解
    目录1、线程池思想概述2、什么是线程池?3、不使用线程池的问题4、线程池的工作原理5、线程池实现的API、参数说明 5.1、谁代表线程池? 5.2、如何得到线程池对象 5.3、ThreadPoolExecutor构造器的参数说明 6、线程池常见面试题 6.1、临时线程什么时候创建啊? 6.2......
  • 线程池的使用:批量导入、数据汇总、异步保存搜索记录
    文章目录1、场景一:MySQL批量导入数据到ES1.1CountDownLatch1.2流程图1.3代码实现1.4效果2、场景二:数据汇总2.1流程图2.2代码实现3、场景三:异步调用3.1需求3.2代码实现1、场景一:MySQL批量导入数据到ES场景:需要将库里的1000万左右的数据量,导入到ES索引库中......
  • GATK不能多线程的问题
    问题:申请了多线程但是只能单线程 17:13:48.941INFOIntelPairHmm-Availablethreads:117:13:48.941INFOIntelPairHmm-Requestedthreads:417:13:48.941WARNIntelPairHmm-Using1availablethreads,but4wererequested 解决方法:exportOMP_N......
  • 线程池
    从上图可以看到,线程被创建出来之后,都处于睡眠态,它们实际上是进入了条件量的等待队列中。而任务都被放入一个链表,被互斥锁保护起来。下面是线程池里面线程们的一生:\1.被创建\2.写遗书(准备好退出处理函数,防止在持有一把锁的状态中死去)\3.试图持有互斥锁(等待任务)\4.判断是......