public ExecutorService 如何定义具体的 executorService

时间: 2024-01-27 17:14:23 浏览: 156

Java使用ExecutorService来停止线程服务

Java 使用 ExecutorService 来停止线程服务 Java 中的 ExecutorService 是一个非常强大的线程池管理工具，它提供了多种方式来停止线程服务。今天，我们将详细介绍如何使用 ExecutorService 来停止线程服务。我们需要了解 ExecutorService 的两个关闭方法：shutdown() 和 shutdownNow()。这两个方法的区别在于它们的安全性和响应性。shutdown() 方法会正常关闭线程池，等待所有任务执行完毕后关闭，而 shutdownNow() 方法会强行关闭线程池，取消所有正在执行的任务。使用 shutdown() 方法来停止线程服务 ----------------------------- shutdown() 方法会等待所有任务执行完毕后关闭线程池。下面是一个使用 shutdown() 方法的示例代码： ```java public void useShutdown() throws InterruptedException { ExecutorService executor = Executors.newFixedThreadPool(10); Runnable runnableTask = () -> { try { TimeUnit.MILLISECONDS.sleep(300); } catch (InterruptedException e) { e.printStackTrace(); } }; executor.submit(runnableTask); executor.shutdown(); executor.awaitTermination(800, TimeUnit.MILLISECONDS); } ``` 在上面的代码中，我们首先创建了一个固定大小的线程池，然后提交了一个任务。随后，我们调用 shutdown() 方法来关闭线程池，并使用 awaitTermination() 方法来等待所有任务执行完毕。使用 shutdownNow() 方法来停止线程服务 ----------------------------- shutdownNow() 方法会强行关闭线程池，取消所有正在执行的任务。下面是一个使用 shutdownNow() 方法的示例代码： ```java public List<Runnable> useShutdownNow() { ExecutorService executor = Executors.newFixedThreadPool(10); Runnable runnableTask = () -> { try { TimeUnit.MILLISECONDS.sleep(300); } catch (InterruptedException e) { e.printStackTrace(); } }; executor.submit(runnableTask); return executor.shutdownNow(); } ``` 在上面的代码中，我们首先创建了一个固定大小的线程池，然后提交了一个任务。随后，我们调用 shutdownNow() 方法来关闭线程池，并返回所有已经提交但是还没有开始的任务。继承 AbstractExecutorService 来获取开始执行但是还没有执行完毕的任务 ---------------------------------------------------------------- 使用 shutdownNow() 方法时，我们可以获取所有已经提交但是还没有开始的任务，但是对于那些已经开始执行但是没有执行完毕的任务，我们无法获取。为了解决这个问题，我们可以继承 AbstractExecutorService 类来自定义一个 ExecutorService。下面是一个继承 AbstractExecutorService 类的示例代码： ```java public class TrackingExecutor extends AbstractExecutorService { private final ExecutorService executorService; private final Set<Runnable> taskCancelledAtShutdown = Collections.synchronizedSet(new HashSet<Runnable>()); public TrackingExecutor(ExecutorService executorService) { this.executorService = executorService; } @Override public void shutdown() { executorService.shutdown(); } @Override public List<Runnable> shutdownNow() { return executorService.shutdownNow(); } @Override public boolean isShutdown() { return executorService.isShutdown(); } @Override public boolean isTerminated() { return executorService.isTerminated(); } @Override public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException { return executorService.awaitTermination(timeout, unit); } @Override public void execute(Runnable command) { executorService.execute(() -> { try { command.run(); } finally { if (isShutdown() && Thread.currentThread().isInterrupted()) { taskCancelledAtShutdown.add(command); } } }); } } ``` 在上面的代码中，我们继承了 AbstractExecutorService 类，并添加了一个 taskCancelledAtShutdown 集合来存储那些已经开始执行但是没有执行完毕的任务。在 execute() 方法中，我们使用 finally 语句来判断任务是否已经开始执行，如果是的话，我们将其添加到 taskCancelledAtShutdown 集合中。使用 ExecutorService 来停止线程服务可以使用 shutdown() 和 shutdownNow() 两个方法。shutdown() 方法会等待所有任务执行完毕后关闭线程池，而 shutdownNow() 方法会强行关闭线程池，取消所有正在执行的任务。同时，我们也可以继承 AbstractExecutorService 类来自定义一个 ExecutorService，以获取开始执行但是还没有执行完毕的任务。

要定义具体的ExecutorService，您可以使用Executors工厂类中的方法之一来创建ExecutorService实例。以下是一些示例代码： 1. 创建一个单线程的ExecutorService： ```java ExecutorService executorService1 = Executors.newSingleThreadExecutor(); ``` 2. 创建一个固定大小的线程池ExecutorService，其中包含10个线程： ```java ExecutorService executorService2 = Executors.newFixedThreadPool(10); ``` 3. 创建一个大小为10的调度线程池ExecutorService： ```java ExecutorService executorService3 = Executors.newScheduledThreadPool(10); ``` 这些示例代码分别创建了不同类型的ExecutorService实例，您可以根据自己的需求选择适合的类型。创建ExecutorService后，您可以使用它来提交任务并执行。

阅读全文

public ExecutorService 如何定义具体的 executorService

相关推荐

在spring boot中使用java线程池ExecutorService的讲解

java 中Executor, ExecutorService 和 Executors 间的不同

@Bean("taskExecutor") public ExecutorService taskExecutor(){

public interface ExecutorService extends Executor

ExecutorService single

ExecutorService 休眠

ExecutorService 用法

ExecutorService threadPool

private final ExecutorService executorService; 提示报错了

解释public final static ExecutorService CachedThreadExecutor = Executors.newCachedThreadPool(r -> new Thread(r, "background-cache-thread"));

ExecutorService配置类

ExecutorService使用示例

ExecutorService 设置线程

使用executorService呢

ExecutorService 如何传参

ExecutorService创建示例

java的ExecutorService

最新推荐

在spring boot中使用java线程池ExecutorService的讲解

Jupyter_关于长期序列预测NeurIPS 2021的自耦分解变压器的代码发布.zip

高清艺术文字图标资源，PNG和ICO格式免费下载

管理建模和仿真的文件

DMA技术：绕过CPU实现高效数据传输

SGM8701电压比较器如何在低功耗电池供电系统中实现高效率运作？

mui框架HTML5应用界面组件使用示例教程

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

【数据传输高速公路】：总线系统的深度解析

如何结合PID算法调整PWM信号来优化电机速度控制？请提供实现这一过程的步骤和代码示例。