Java ExecutorService 示例-程序员宅基地

在本教程中，我们将了解Java 中的executorservice。我们已经知道 Java 与需要在线程中并发执行任务的多线程应用程序一起工作非常有效。

对于任何应用程序来说，同时执行大量线程都是具有挑战性的。因此，为了克服这个问题，Java 提供了 ExecutorService 接口，它是 Executors 框架的一个子接口。

在本文中，我们将了解如何创建 ExecutorService。并且，如何将要执行的任务提交给执行器服务，我们还讨论了如何查看这些任务的结果。

最后，我们将研究如何在需要时再次关闭 ExecutorService。

什么是执行器框架？

我们更容易同时创建和执行一两个线程。但是当线程数量增加到相当多的时候，就变得很困难了。许多多线程应用程序有数百个线程同时运行。

因此，需要将线程的创建与应用程序中的线程管理分开。

Java ExecutorService 接口位于 java.util.concurrent 包中。该接口代表了一种异步执行机制，可以在后台并发执行多个任务。

ExecutorService 执行的任务

执行程序服务框架有助于在应用程序中创建和管理线程。执行器框架执行以下任务。

1、线程创建： Executor服务提供了很多线程创建的方法。这有助于并发运行应用程序。

2. 线程管理： Executor 服务也有助于管理线程生命周期。在提交任务执行之前，我们不必担心线程是处于活动状态、忙碌状态还是死状态。

3. 任务提交与执行： Executor 框架还提供了在线程池中提交任务的方法。它还提供了决定线程是否执行的权力。

任务委托

下图表示将任务委托给 Java ExecutorService 进行异步执行的线程：

创建 ExecutorService

ExecutorService 是 Java 中的一个接口。此接口的实现可以异步方式执行 Runnable 或 Callable 类。我们必须注意，以同步方式调用 Runnable 接口的 run() 方法是调用一个方法。

我们可以通过以下方式创建 ExecutorService 接口的实例：

1. Executors类

Executors 类是一个实用程序类，它提供工厂方法来创建 Executor 服务接口的实现。

//Executes only one thread
ExecutorService es = Executors.newSingleThreadExecutor();

//Internal management of thread pool of 2 threads
ExecutorService es = Executors.newFixedThreadPool(2);

//Internally managed thread pool of 10 threads to run scheduled tasks
ExecutorService es = Executors.newScheduledThreadPool(10);

2. 构造函数

下面的语句创建了一个线程池执行器。我们使用最小线程数为 10 的构造函数创建它。最大线程数为 100。保持活动时间为 5 毫秒。而且，有一个阻塞队列来监视将来的任务。

import java.util.concurrent.ExecutorService;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.LinkedBlockingQueue;
ExecutorService exService = new ThreadPoolExecutor(10, 100, 5L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue < Runnable > ());

Java ExecutorService 示例

Java中的ExecutorService是executor框架的一个子接口。它提供了某些功能来管理应用程序的线程生命周期。还有一个 submit() 方法可以接受可运行和可调用对象。

在下面的示例中，我们将创建一个单线程的 ExecutorService，然后提交要在线程内执行的任务。

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class Example {
  public static void main(String[] args) {
    System.out.println("Inside: " + Thread.currentThread().getName());
    System.out.println("Creating ExecutorService");
    ExecutorService executorservice = Executors.newSingleThreadExecutor();
    System.out.println("Creating a Runnable");
    Runnable runnable = () - >{
      System.out.println("Inside: " + Thread.currentThread().getName());
    };
    System.out.println("Submitting the task specified by the runnable to the executorservice");
    executorservice.submit(runnable);
  }
}

输出：

Inside: main
Creating ExecutorService
Creating a Runnable
Submitting the task specified by the runnable to the executorservice
Inside: pool-1-thread-1

注意：运行上述程序时，程序永远不会退出。您需要明确关闭它，因为执行程序服务一直在侦听新任务。

Java ExecutorService 实现

ExecutorService 与线程池非常相似。java.util.concurrent包中ExecutorService的实现是线程池实现。java.util.concurrent 包中有以下 ExecutorService 的实现：

1.线程池执行器

ThreadPoolExecutor 使用其内部池线程之一执行指定的任务。

创建一个线程池执行器

int corethreadPoolSize = 10;
int maxPoolSize = 15;
long keepAliveTime = 6000;
ExecutorService es = new threadPoolExecutor(corethreadPoolSize, maxPoolSize, keepAliveTime, TimeUnit.MILLISECONDS, new LinkedBlockingQueue < Runnable > ());

2. ScheduledThreadPoolExecutor

ScheduledThreadPoolExecutor 是一个 ExecutorService，它可以调度任务在延迟后运行或在每次执行之间以固定的时间间隔重复执行。

创建 ScheduledthreadPoolExecutor

ScheduledExecutorService scheduledexecutorservice = Executors.newScheduledThreadPool(5);
ScheduledFuture scheduledfuture = scheduledExecutorService.schedule(new Callable() {
  public Object call() throws Exception {
    System.out.println("executed");
    return "called";
  }
},
5, TimeUnit.SECONDS);

Java 中的 ExecutorService 使用

以下是将要执行的任务委托给 ExecutorService 的不同方法：

execute(Runnable)
submit(Runnable)
submit(Callable)
invokeAny(…)
invokeAll(…)

1.在java中执行Runnable

Java 的 ExecutorService execute(Runnable) 方法接受一个 Runnable 对象并异步执行它。

下面是使用 ExecutorService 执行 Runnable 的示例：

ExecutorService executorService = Executors.newSingleThreadExecutor();
executorService.execute(new Runnable() {
  public void run() {
    System.out.println("asynchronous task");
  }
});
executorService.shutdown();

2.在java中提交Runnable

submit(Runnable) 方法采用 Runnable 实现并返回一个 Future 对象。我们可以使用这个 Future 对象来检查 Runnable 是否已完成执行。

这是一个 Java ExecutorService submit() 示例：

Future future = executorService.submit(new Runnable() {
  public void run() {
    System.out.println(" asynchronous task ");
}
});
future.get();

3. 在 Java 中提交 Callable

Java submit(Callable) 方法类似于 submit(Runnable) 方法，除了它采用 Callable 对象而不是 Runnable。我们可以使用 submit(Callable) 方法返回的 Java Future 对象获取 Callable 的结果。

这是一个 ExecutorService Callable 示例：

Future future = executorService.submit(new Callable() {
  public Object call() throws Exception {
    System.out.println("Asynchronous callable");
    return "Callable Result";
  }
});
System.out.println("future.get() = "
future.get());

输出：

Asynchroous callable
future.get = Callable Result

4.java中的invokeAny()

invokeAny() 方法采用 Callable 对象的集合或子接口。此方法返回 Callable 对象之一的结果。无法保证我们将获得哪些 Callable 结果。

例如：

public class ExecutorServiceExample {
  public static void main(String[] args) throws ExecutionException,
  InterruptedException {
    ExecutorService es = Executors.newSingleThreadExecutor();
    Set < Callable < String >> callable = new HashSet < Callable < String >> ();
    callable.add(new Callable < String > () {
      public String call() throws Exception {
        return "Task 1";
      }
    });
    callable.add(new Callable < String > () {
      public String call() throws Exception {
        return "Task 2";
      }
    });
    callable.add(new Callable < String > () {
      public String call() throws Exception {
        return "Task 3";
      }
    });
    String result = es.invokeAny(callable);
    System.out.println("result = " + result);
    executorService.shutdown();
  }
}

输出：

result = Task 1

5. Java 中的 invokeAll()

invokeAll() 方法调用我们在集合中作为参数传递给它的所有 Callable 对象。这个方法返回一个 Future 对象的列表，通过它我们可以获得每个 Callable 的执行结果。

例如：

public class ExecutorServiceExample {
  public static void main(String[] args) throws InterruptedException,
  ExecutionException {
    ExecutorService executorService = Executors.newSingleThreadExecutor();
    Set < Callable < String >> callable = new HashSet < Callable < String >> ();
    callable.add(new Callable < String > () {
      public String call() throws Exception {
        return "Task 1";
      }
    });
    callable.add(new Callable < String > () {
      public String call() throws Exception {
        return "Task 2";
      }
    });
    callable.add(new Callable < String > () {
      public String call() throws Exception {
        return "Task 3";
      }
    });
    java.util.List < Future < String >> futures = executorService.invokeAll(callable);

    for (Future < String > future: futures) {
      System.out.println("future.get = " + future.get());
    }
    executorService.shutdown();

  }
}

输出：

future.get = Task 1
future.get = Task 3
future.get = Task 2

Java 中的 ExecutorService 关闭

当我们使用 Java ExecutorService 进行竞争时，我们应该关闭它，这样线程就不会继续运行。在某些情况下，通过 main() 方法启动应用程序并且主线程退出我们的应用程序。

在这种情况下，如果应用程序中有活动的 ExecutorService，应用程序将继续运行。ExecutorService 中存在的这些活动线程可防止 JVM 关闭。

让我们讨论关闭 Executor 服务的方法：

1. Java中的shutdown()

我们调用shutdown() 方法来终止ExecutorService 中的线程。这不会立即关闭 ExecutorService，但它将不再接受新任务。

一旦所有线程完成其当前任务，ExecutorService 就会关闭。在我们调用 shutdown() 之前，所有提交给 ExecutorService 的任务都会被执行。

以下是执行 Java ExecutorService 关闭的示例：

executorService.shutdown();

2. Java 中的 shutdownNow()

如果我们需要立即关闭 ExecutorService，我们可以调用 shutdownNow() 方法。此方法将尝试立即停止所有正在执行的任务，并跳过所有已提交但未处理的任务。

但是，将无法保证执行的任务。它们可能会停止，也可能会一直执行到最后。

例如：

executorService.shutdownNow();

3. Java 中的 awaitTermination()

ExecutorService awaitTermination() 方法会阻止调用它的线程，直到 ExecutorService 完全关闭，或者直到发生给定的超时。通常在调用 shutdown() 或 shutdownNow() 之后调用 awaitTermination() 方法。

下面是调用 ExecutorService awaitTermination() 方法的示例：

executorService.awaitTermination();

Java 中的 Runnable 与 Callable 接口

Runnable 接口几乎类似于 Callable 接口。Runnable 和 Callable 接口都表示一个线程或一个 ExecutorService 可以并发执行的任务。两个接口中都有一个方法。

Runnable 和 Callable 接口之间有一个小区别。当我们看到接口声明时，两个接口之间的区别就很明显了。

下面是 Runnable 接口的声明：

public interface Runnable {
  public void run();
}

这是 Callable 接口的声明：

public interface Callable {
  public Object call() throws Exception;
}

Runnable 的 run() 方法和 Callable 的 call() 方法的主要区别在于 call() 可以抛出异常，而 run() 不能抛出异常，除了未经检查的异常——RuntimeException 的子类。

call() 和 run() 之间的另一个区别是 call() 方法可以从方法调用返回一个对象。

在 Java 中取消任务

我们也可以取消一个提交给 Java 的 ExecutorService 的 Runnable 或 Callable 任务。我们可以通过调用 Future 的 cancel() 方法来取消任务。只有在任务尚未开始执行时才可以取消任务。

例如：

Future.cancel();

结论

最后我们看到 ExecutorService 有助于最小化复杂的代码。它还有助于通过内部利用线程池来管理资源。程序员应该小心避免一些常见的错误。

例如，在完成不再需要的任务和服务后，始终关闭执行器服务。否则，JVM 永远不会终止，通常。在本教程中，我们涵盖了 Java 中 Executor 服务的每一个概念。

本文链接：https://blog.csdn.net/allway2/article/details/118793216

原作者删帖不实内容删帖广告或垃圾文章投诉

智能推荐

【史上最易懂】马尔科夫链-蒙特卡洛方法：基于马尔科夫链的采样方法，从概率分布中随机抽取样本，从而得到分布的近似_马尔科夫链期望怎么求-程序员宅基地

文章浏览阅读1.3k次，点赞40次，收藏19次。虽然你不能直接计算每个房间的人数，但通过马尔科夫链的蒙特卡洛方法，你可以从任意状态（房间）开始采样，并最终收敛到目标分布（人数分布）。然后，根据一个规则（假设转移概率是基于房间的人数，人数较多的房间具有较高的转移概率），你随机选择一个相邻的房间作为下一个状态。比如在巨大城堡，里面有很多房间，找到每个房间里的人数分布情况（每个房间被访问的次数），但是你不能一次进入所有的房间并计数。但是，当你重复这个过程很多次时，你会发现你更有可能停留在人数更多的房间，而在人数较少的房间停留的次数较少。_马尔科夫链期望怎么求

linux以root登陆命令,su命令和sudo命令，以及限制root用户登录-程序员宅基地

文章浏览阅读3.9k次。一、su命令su命令用于切换当前用户身份到其他用户身份，变更时须输入所要变更的用户帐号与密码。命令su的格式为：su [-] username1、后面可以跟 ‘-‘ 也可以不跟，普通用户su不加username时就是切换到root用户，当然root用户同样可以su到普通用户。 ‘-‘ 这个字符的作用是，加上后会初始化当前用户的各种环境变量。下面看下加‘-’和不加‘-’的区别：root用户切换到普通..._限制su root登陆

精通VC与Matlab联合编程（六）_精通vc和matlab联合编程六-程序员宅基地

文章浏览阅读1.2k次。精通VC与Matlab联合编程（六）作者：邓科下载源代码浅析VC与MATLAB联合编程浅析VC与MATLAB联合编程浅析VC与MATLAB联合编程浅析VC与MATLAB联合编程浅析VC与MATLAB联合编程　　Matlab C/C++函数库是Matlab扩展功能重要的组成部分,包含了大量的用C/C++语言重新编写的Matlab函数,主要包括初等数学函数、线形代数函数、矩阵操作函数、数值计算函数_精通vc和matlab联合编程六

Asp.Net MVC2中扩展ModelMetadata的DescriptionAttribute。-程序员宅基地

文章浏览阅读128次。在MVC2中默认并没有实现DescriptionAttribute（虽然可以找到这个属性，通过阅读MVC源码，发现并没有实现方法），这很不方便，特别是我们使用EditorForModel的时候，我们需要对字段进行简要的介绍，下面来扩展这个属性。新建类 DescriptionMetadataProvider然后重写DataAnnotationsModelMetadataPro..._asp.net mvc 模型description

领域模型架构 eShopOnWeb项目分析上-程序员宅基地

文章浏览阅读1.3k次。一.概述　　本篇继续探讨web应用架构，讲基于DDD风格下最初的领域模型架构，不同于DDD风格下CQRS架构，二者架构主要区别是领域层的变化。架构的演变是从领域模型到C..._eshoponweb

Springboot中使用kafka_springboot kafka-程序员宅基地

文章浏览阅读2.6w次，点赞23次，收藏85次。首先说明，本人之前没用过zookeeper、kafka等，尚硅谷十几个小时的教程实在没有耐心看，现在我也不知道分区、副本之类的概念。用kafka只是听说他比RabbitMQ快，我也是昨天晚上刚使用，下文中若有讲错的地方或者我的理解与它的本质有偏差的地方请包涵。此文背景的环境是windows，linux流程也差不多。官网下载kafka，选择Binary downloads Apache Kafka 解压在D盘下或者什么地方，注意不要放在桌面等绝对路径太长的地方打开conf_springboot kafka

随便推点

VS2008+水晶报表发布后可能无法打印的解决办法_水晶报表不能打印-程序员宅基地

文章浏览阅读1k次。编好水晶报表代码,用的是ActiveX模式,在本机运行,第一次运行提示安装ActiveX控件,安装后,一切正常,能正常打印,但发布到网站那边运行,可能是一闪而过,连提示安装ActiveX控件也没有,甚至相关的功能图标都不能正常显示,再点"打印图标"也是没反应解决方法是: 1.先下载"PrintControl.cab" http://support.businessobjects.c_水晶报表不能打印

一. UC/OS-Ⅱ简介_ucos-程序员宅基地

文章浏览阅读1.3k次。绝大部分UC/OS-II的源码是用移植性很强的ANSI C写的。也就是说某产品可以只使用很少几个UC/OS-II调用，而另一个产品则使用了几乎所有UC/OS-II的功能，这样可以减少产品中的UC/OS-II所需的存储器空间（RAM和ROM）。UC/OS-II是为嵌入式应用而设计的，这就意味着，只要用户有固化手段（C编译、连接、下载和固化）， UC/OS-II可以嵌入到用户的产品中成为产品的一部分。1998年uC/OS-II，目前的版本uC/OS -II V2.61，2.72。1.UC/OS-Ⅱ简介。_ucos