Java一分钟之线程池:ExecutorService与Future

本文涉及的产品
实时数仓Hologres,5000CU*H 100GB 3个月
智能开放搜索 OpenSearch行业算法版,1GB 20LCU 1个月
实时计算 Flink 版,1000CU*H 3个月
简介: 【5月更文挑战第12天】Java并发编程中,`ExecutorService`和`Future`是关键组件,简化多线程并提供异步执行能力。`ExecutorService`是线程池接口,用于提交任务到线程池,如`ThreadPoolExecutor`和`ScheduledThreadPoolExecutor`。通过`submit()`提交任务并返回`Future`对象,可检查任务状态、获取结果或取消任务。注意处理`ExecutionException`和避免无限等待。实战示例展示了如何异步执行任务并获取结果。理解这些概念对提升并发性能至关重要。

在Java并发编程的世界里,线程池是提高程序性能、管理线程生命周期的利器。ExecutorServiceFuture作为Java并发包中的核心组件,它们不仅简化了多线程编程的复杂度,还为我们提供了强大的异步执行和结果获取能力。本文将深入浅出地探讨这两个概念,揭示常见问题、易错点及避免策略,并辅以代码示例,帮助大家更好地理解和应用。
image.png

ExecutorService:线程池的指挥官

简介

ExecutorServicejava.util.concurrent包下的接口,它是线程池的主接口,提供了执行任务的高级接口。通过它,我们可以提交任务(Runnable或Callable类型)到线程池中执行,而无需关心线程的创建、调度和销毁等细节。

常见实现类

  • ThreadPoolExecutor:最常用的线程池实现,提供了高度可配置的线程池参数,如核心线程数、最大线程数、线程存活时间等。
  • ScheduledThreadPoolExecutor:支持定时及周期性任务执行的线程池。

创建线程池

ExecutorService executor = Executors.newFixedThreadPool(10); // 创建固定大小线程池

提交任务

executor.submit(() -> System.out.println("Running task in thread pool."));

关闭线程池

executor.shutdown(); // 平缓关闭,不再接受新任务,等待现有任务完成
// 或者
executor.shutdownNow(); // 立即关闭,尝试中断正在执行的任务

Future:异步任务的未来

简介

当你通过submit(Callable<T> task)方法向ExecutorService提交一个Callable任务时,返回的是一个Future<T>对象。这个Future代表了异步计算的结果,提供了检查计算是否完成、获取计算结果以及取消计算的方法。

常用方法

  • isDone(): 判断任务是否已完成。
  • get(): 阻塞等待直到任务完成并返回结果,可能会抛出异常。
  • get(long timeout, TimeUnit unit): 在指定时间内等待任务完成。
  • cancel(boolean mayInterruptIfRunning): 尝试取消任务,如果任务已经开始执行且mayInterruptIfRunning为true,则尝试中断执行。

易错点与避免策略

易错点1:忽视异常处理

Callable任务中抛出的异常会被封装进ExecutionException,调用Future.get()时必须妥善处理这一异常。

避免策略

try {
   
   
    String result = future.get();
} catch (InterruptedException e) {
   
   
    Thread.currentThread().interrupt(); // 重新设置中断标志
    // 处理中断
} catch (ExecutionException e) {
   
   
    // 处理任务执行时抛出的异常
    Throwable cause = e.getCause();
    // ...
}

易错点2:无限等待

使用get()方法时,如果没有设置超时,程序可能会因为等待任务完成而无限阻塞。

避免策略

总是考虑使用带超时参数的get(long timeout, TimeUnit unit)方法,或者在合适的时机检查isDone()状态。

实战示例:异步任务与结果获取

import java.util.concurrent.*;

public class ExecutorServiceFutureDemo {
   
   

    public static void main(String[] args) throws ExecutionException, InterruptedException {
   
   
        ExecutorService executor = Executors.newFixedThreadPool(1);

        Future<Integer> future = executor.submit(() -> {
   
   
            Thread.sleep(2000); // 模拟耗时操作
            return 42; // 计算结果
        });

        System.out.println("Task submitted, doing something else...");

        // 非阻塞方式检查结果
        while (!future.isDone()) {
   
   
            System.out.println("Task is not done yet...");
            Thread.sleep(500);
        }

        // 获取结果
        System.out.println("Result: " + future.get());

        executor.shutdown();
    }
}

结语

通过ExecutorServiceFuture,Java为我们提供了一套强大且灵活的并发编程工具集。理解它们的工作原理、掌握常见的使用技巧及避免常见陷阱,对于提升程序的并发性能和稳定性至关重要。希望本文能帮助你更深入地掌握这两项技术,让你在编写高效并发程序的道路上更进一步。

目录
相关文章
|
12天前
|
数据采集 存储 弹性计算
高并发Java爬虫的瓶颈分析与动态线程优化方案
高并发Java爬虫的瓶颈分析与动态线程优化方案
Java 数据库 Spring
47 0
|
24天前
|
算法 Java
Java多线程编程:实现线程间数据共享机制
以上就是Java中几种主要处理多线程序列化资源以及协调各自独立运行但需相互配合以完成任务threads 的技术手段与策略。正确应用上述技术将大大增强你程序稳定性与效率同时也降低bug出现率因此深刻理解每项技术背后理论至关重要.
58 16
|
1月前
|
缓存 并行计算 安全
关于Java多线程详解
本文深入讲解Java多线程编程,涵盖基础概念、线程创建与管理、同步机制、并发工具类、线程池、线程安全集合、实战案例及常见问题解决方案,助你掌握高性能并发编程技巧,应对多线程开发中的挑战。
|
1月前
|
数据采集 存储 前端开发
Java爬虫性能优化:多线程抓取JSP动态数据实践
Java爬虫性能优化:多线程抓取JSP动态数据实践
|
2月前
|
Java API 调度
从阻塞到畅通:Java虚拟线程开启并发新纪元
从阻塞到畅通:Java虚拟线程开启并发新纪元
300 83
|
2月前
|
安全 算法 Java
Java 多线程:线程安全与同步控制的深度解析
本文介绍了 Java 多线程开发的关键技术,涵盖线程的创建与启动、线程安全问题及其解决方案,包括 synchronized 关键字、原子类和线程间通信机制。通过示例代码讲解了多线程编程中的常见问题与优化方法,帮助开发者提升程序性能与稳定性。
139 0
|
存储 缓存 Java
JAVA并发编程系列(11)线程池底层原理架构剖析
本文详细解析了Java线程池的核心参数及其意义,包括核心线程数量(corePoolSize)、最大线程数量(maximumPoolSize)、线程空闲时间(keepAliveTime)、任务存储队列(workQueue)、线程工厂(threadFactory)及拒绝策略(handler)。此外,还介绍了四种常见的线程池:可缓存线程池(newCachedThreadPool)、定时调度线程池(newScheduledThreadPool)、单线程池(newSingleThreadExecutor)及固定长度线程池(newFixedThreadPool)。
|
安全 Java 数据库
一天十道Java面试题----第四天(线程池复用的原理------>spring事务的实现方式原理以及隔离级别)
这篇文章是关于Java面试题的笔记,涵盖了线程池复用原理、Spring框架基础、AOP和IOC概念、Bean生命周期和作用域、单例Bean的线程安全性、Spring中使用的设计模式、以及Spring事务的实现方式和隔离级别等知识点。
|
缓存 监控 Java
(十)深入理解Java并发编程之线程池、工作原理、复用原理及源码分析
深入理解Java并发编程之线程池、工作原理、复用原理及源码分析
181 0