ExecutorService 线程池

简介: 1.ExecutorService java.util.concurrent.ExecutorService 接口。用来设置线程池并执行多线程任务。它有以下几个方法。 Future<?> java.util.concurrent.ExecutorService.submit(Runnable task) 提交任务并执行,返回代表这个任务的future对象。在任务成功执行

1.ExecutorService

java.util.concurrent.ExecutorService

接口。用来设置线程池并执行多线程任务。它有以下几个方法。

Future<?> java.util.concurrent.ExecutorService.submit(Runnable task)

提交任务并执行,返回代表这个任务的future对象。在任务成功执行完毕之前,future.get()会返回null。

<E> Future<E> java.util.concurrent.ExecutorService.submit(Callable<E> task)
提交一个有返回值的任务并运行。在任务成功执行完毕之前,future.get()会阻塞。

void java.util.concurrent.ExecutorService.shutdown()
启动一个有序的关闭,关闭那些先前提交过的已执行完毕的任务。此时ExecutorService不再接受新的任务。

List<Runnable> java.util.concurrent.ExecutorService.shutdownNow()
尝试终止正在执行的任务,终止等待执行的线程,返回等待执行的线程列表。

boolean java.util.concurrent.ExecutorService.isTerminated()

进程池已经被shutdown且所有任务均已完成时,返回true。

2.Executors

java.util.concurrent.Executors

工厂类,可以通过静态方法获得实现ExecutorService接口的对象。

主要有下面几种,见表2-1.

表2-1 常见的ExecutorService实现类


2.1 ThreadPoolExecutor

ExecutorService java.util.concurrent.Executors. newCachedThreadPool()
返回的是java.util.concurrent.ThreadPoolExecutor对象。

java.util.concurrent.ThreadPoolExecutor

类。用于接收提交的任务,放到线程池中运行。

java.util.concurrent.ThreadPoolExecutor.ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler)

构造函数。

corePoolSize:最小线程数。一般会取Runtime.getRuntime().availableProcessors()。
maximumPoolSize:任务变多时,最大线程数。一般会取corePoolSize*20.
keepAliveTime:多开的线程用完后,等待一定时间再被回收。
unit:时间单位。
workQueue:当线程池已满,新任务不能立即执行的时候,就会放进此等待队列。
threadFactory:创建线程的工厂。
java.util.concurrent.ThreadPoolExecutor. ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue)

ThreadPoolExecutor构造函数的重载。

 long java.util.concurrent.ThreadPoolExecutor.getCompletedTaskCount()
返回执行完毕的任务数,是近似值。
 long java.util.concurrent.ThreadPoolExecutor.getTaskCount()
返回加入执行计划的所有任务总数,是近似值。
 int java.util.concurrent.ThreadPoolExecutor.getActiveCount()
 返回正在执行任务的的活动状态的线程数,是近似值。

java.util.concurrent. ThreadFactory
接口,它只有下面一个方法:
Thread java.util.concurrent.ThreadFactory. newThread(Runnable r)
生成Thread并返回。

2.2 ScheduledThreadPoolExecutor

java.util.concurrent.ScheduledThreadPoolExecutor.ScheduledThreadPoolExecutor(int corePoolSize)
构造函数,创建“计划线程池执行器”。此类为ExecutorService的实现类。

ScheduledFuture<?> java.util.concurrent.ScheduledExecutorService.scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit)
开辟新线程执行任务。延迟initialDelay时间后开始执行command,并且按照period时间周期性重复调用,并且保证在上次运行完后才会执行下一次,周期时间不包括command运行时间。

ScheduledFuture<?> java.util.concurrent.ScheduledExecutorService.scheduleAtFixedRate(Runnable command, long initialDelay, long delay, TimeUnit unit)

延迟initialDelay时间后开始执行command,并且按照period时间周期性重复调用。周期时间包括command运行时间,如果周期时间比command运行时间短,则command运行完毕后,立刻重复运行。


3.线程异常

任务中抛出未被捕获的异常 不会造成线程池的线程消失。线程池对此做了保护机制。查看jdk源码可以找到这部分代码。

4.任务过多

java.util.concurrent.RejectedExecutionHandler
接口,它只有下面一个方法:
void rejectedExecution(Runnable r, ThreadPoolExecutor executor)
当提交的任务不能被ThreadPoolExecutor执行时(如等待队列已满),调用此函数。
java.util.concurrent.ThreadPoolExecutor.AbortPolicy
RejectedExecutionHandler的实现类。它会抛出异常RejectedExecutionException。
java.util.concurrent.ThreadPoolExecutor.DiscardPolicy
RejectedExecutionHandler的实现类。它的函数体为空,即什么也不做。

目录
相关文章
|
5月前
|
Java 开发者
Java面试题:请解释内存泄漏的原因,并说明如何使用Thread类和ExecutorService实现多线程编程,请解释CountDownLatch和CyclicBarrier在并发编程中的用途和区别
Java面试题:请解释内存泄漏的原因,并说明如何使用Thread类和ExecutorService实现多线程编程,请解释CountDownLatch和CyclicBarrier在并发编程中的用途和区别
59 0
|
6月前
|
缓存 并行计算 Java
重温JAVA线程池精髓:Executor、ExecutorService及Executors的源码剖析与应用指南
重温JAVA线程池精髓:Executor、ExecutorService及Executors的源码剖析与应用指南
|
5月前
|
设计模式 安全 NoSQL
Java面试题:结合单例模式与Java内存管理,设计一个线程安全的单例类?分析Java多线程工具类ExecutorService与Java并发工具包中的工具类,设计一个Java并发框架的分布式锁实现
Java面试题:结合单例模式与Java内存管理,设计一个线程安全的单例类?分析Java多线程工具类ExecutorService与Java并发工具包中的工具类,设计一个Java并发框架的分布式锁实现
69 0
|
5月前
|
存储 安全 Java
Java面试题:如何在Java应用中实现有效的内存优化?在多线程环境下,如何确保数据的线程安全?如何设计并实现一个基于ExecutorService的任务处理流程?
Java面试题:如何在Java应用中实现有效的内存优化?在多线程环境下,如何确保数据的线程安全?如何设计并实现一个基于ExecutorService的任务处理流程?
47 0
|
7月前
|
Java 调度
Java一分钟之线程池:ExecutorService与Future
【5月更文挑战第12天】Java并发编程中,`ExecutorService`和`Future`是关键组件,简化多线程并提供异步执行能力。`ExecutorService`是线程池接口,用于提交任务到线程池,如`ThreadPoolExecutor`和`ScheduledThreadPoolExecutor`。通过`submit()`提交任务并返回`Future`对象,可检查任务状态、获取结果或取消任务。注意处理`ExecutionException`和避免无限等待。实战示例展示了如何异步执行任务并获取结果。理解这些概念对提升并发性能至关重要。
146 5
|
Java
ExecutorService、Callable、Future实现有返回结果的多线程原理解析
ExecutorService、Callable、Future实现有返回结果的多线程原理解析
78 0
|
缓存 Java
Java线程池ExecutorService
Java线程池ExecutorService
108 0
|
安全 Java Apache
多线程的使用,避免ExecutorService 的创建处理
多线程的使用,避免ExecutorService 的创建处理
96 0
多线程的使用,避免ExecutorService 的创建处理
|
存储 安全
使用ExecutorService来停止线程服务
使用ExecutorService来停止线程服务
|
Java
Java多线程之Executor框架:Callable、Future、Executor和ExecutorService
Executor框架是指JDK 1.5中引入的一系列并发库中与Executor相关的功能类,包括Executor、Executors、ExecutorService、Future、Callable等。
1495 0