ExecutorService pool = Executors.newFixedThreadPool(taskSize)

时间: 2023-10-25 16:00:28 浏览: 137

Executor,Executors,ExecutorService比较.docx

Executors：是java.util.concurrent包下的一个类，提供了若干个静态方法，用于生成不同类型的线程池。Executors一共可以创建下面这四类线程池： 1.newFixedThreadPool创建一个可缓存线程池，如果线程池长度超过处理需要，可灵活回收空闲线程，若无可回收，则新建线程。`` 2.newFixedThreadPool 创建一个定长线程池，可控制线程最大并发数，超出的线程会在队列中等待。 3.newScheduledThreadPool 创建一个线程池，它可安排在给定延迟后运行命令或者定期地执行。 4.newSingleThreadExecutor 创建一个使用单个 worker 线程的 Executor，以无界队列方式来运行该线程。它只会用唯一的工作线程来执行任务，保证所有任务按照指定顺序(FIFO, LIFO, 优先级)执行。`` 【Executor、Executors和ExecutorService详解】在Java并发编程中，`Executor`、`Executors`和`ExecutorService`是核心组件，它们帮助开发者高效管理线程资源，提高程序的并发性能。理解这三个概念的区别和用途是编写高性能并发程序的关键。 1. **Executor** `Executor`是Java线程池的顶级接口，它只有一个方法`execute(Runnable command)`，用于执行传入的任务。`Executor`并不直接创建线程，而是通过实现它的子接口或类来完成。通常，我们不会直接使用`Executor`，而是使用它的子接口`ExecutorService`，因为`ExecutorService`提供了更多的功能，如任务的提交、管理和关闭线程池。 2. **Executors** `Executors`是`java.util.concurrent`包下的工具类，它提供了多个静态工厂方法，用于创建不同类型的线程池。常见的线程池类型有： - **newFixedThreadPool(int nThreads)**：创建一个固定大小的线程池。线程池的大小一旦设定就不可变，如果当前任务数量超过了线程数量，新任务会被放入阻塞队列等待执行。 - **newCachedThreadPool()**：创建一个可缓存的线程池。线程池会尽可能重用已存在的线程，如果没有可用线程，会新建线程，当线程空闲时间超过60秒，线程会被终止。 - **newScheduledThreadPool(int corePoolSize)**：创建一个定长的调度线程池，支持定时及周期性任务执行。它可以安排任务在指定延迟后运行，或者定期执行。 - **newSingleThreadExecutor()**：创建一个单线程的线程池，所有任务都在同一个线程中按顺序执行，确保任务的顺序性。 3. **ExecutorService** `ExecutorService`是`Executor`的子接口，它扩展了`Executor`的功能，提供了更丰富的操作线程池的方法，如： - **execute(Runnable)**：从`Executor`继承，用于执行任务。 - **submit(Runnable)**：提交一个`Runnable`任务，返回一个`Future`对象，可以用来检查任务状态或获取结果（如果任务支持）。 - **submit(Callable)**：提交一个`Callable`任务，同样返回`Future`对象，`Callable`的任务可以有返回值。 - **invokeAny**(Collection<Callable<T>> tasks)**：在给定的任务列表中，选择并执行一个任务，返回其结果。 - **invokeAll**(Collection<Callable<T>> tasks)**：执行所有的任务，返回一个包含每个任务结果的`Future`列表。 - **shutdown()**：关闭线程池，不再接受新的任务，但会等待已提交的任务执行完。 - **shutdownNow()**：尝试停止所有正在执行的任务，不再接受新任务，但可能无法立即停止所有任务。使用`ExecutorService`示例： ```java ExecutorService executorService = Executors.newFixedThreadPool(5); Future<Integer> future = executorService.submit(() -> { int result = computeExpensiveValue(); return result; }); executorService.shutdown(); try { Integer value = future.get(); // 等待任务执行完成并获取结果 System.out.println("Computed value: " + value); } catch (InterruptedException | ExecutionException e) { e.printStackTrace(); } ``` 在这个例子中，`ExecutorService`被用来提交一个计算任务，`submit()`返回的`Future`对象用于获取任务的执行结果。总结来说，`Executor`定义了任务执行的基本行为，`Executors`是创建线程池的工厂，而`ExecutorService`则提供了管理和控制线程池的能力。在实际编程中，我们通常通过`Executors`创建线程池，然后利用`ExecutorService`的特性来执行和管理任务。了解这些概念和用法，有助于我们构建高效、稳定的多线程环境。

这段代码创建了一个固定大小的线程池，其中taskSize是指定的线程池的大小。它使用ExecutorService接口来表示线程池，并通过Executors类的静态方法newFixedThreadPool来创建线程池实例。该线程池会为每个提交的任务创建一个线程，直到达到指定的线程池大小。如果所有线程都处于活动状态，而新的任务被提交到线程池，那么这些任务将等待直到有可用的线程。当一个线程完成任务后，它将被重新使用来执行新的任务。通过使用线程池，可以避免频繁地创建和销毁线程，从而提高程序的性能和效率。同时，线程池还提供了一些额外的功能，如线程池的关闭和任务的取消等。

阅读全文

ExecutorService pool = Executors.newFixedThreadPool(taskSize)

相关推荐

java 线程池例子ThreadPoolExecutor

线程池实例：使用Executors和ThreadPoolExecutor

ExecutorService cachePool = Executors.newFixedThreadPool(1);

ExecutorService es = new Executors.newFixedThreadPool(5);

ExecutorService executorService = Executors.newCachedThreadPool();报错

Executors.newFixedThreadPool使用方法

Executors.newFixedThreadPool 线程执行代码

ThreadFactory threadFactory = Executors.defaultThreadFactory();都有哪些？如何使用？

Executors.newFixedThreadPoo 使用方法

Field pool in com.hszy.wms.rabbit.RabbitHandleService required a bean of type 'java.util.concurrent.ExecutorService' that could not be found.

java 线程池管理类：Executors_.docx

运用JAVA的concurrent.ExecutorService线程池实现socket的TCP和UDP连接.doc

5_Executors源码阅读1

Executors 框架详解及最佳实践

Java中的线程池：Executors框架详解

【线程池高级配置】：定制Executors的最佳实践（性能调优秘籍）

查看 ExecutorService 的大小

Shutting down ExecutorService 'poolTaskExecutor

最新推荐

java简单实现多线程及线程池实例详解

数学建模拟合与插值.ppt

MATLAB实现小波阈值去噪：Visushrink硬软算法对比

管理建模和仿真的文件

【交互特征的影响】：分类问题中的深入探讨，如何正确应用交互特征

c语言从链式队列 中获取头部元素并返回其状态的函数怎么写

易语言实现画板图像缩放功能教程

"互动学习：行动中的多样性与论文攻读经历"

【交互特征：优化与调试的艺术】：实战技巧，提升回归模型与分类模型的性能

用IDEA写一个高速收费系统框架附带代码

c语言从链式队列中获取头部元素并返回其状态的函数怎么写