首页 > 编程语言 >Java线程池中的execute和submit

Java线程池中的execute和submit

时间:2023-02-01 15:36:05浏览次数:58  
标签:execute Java 抛出 submit Future 线程 executorService 方法

一、概述

execute和submit都是线程池中执行任务的方法。

execute是Executor接口中的方法

public interface Executor {

    void execute(Runnable command);
}

submit是ExecuteService接口中的方法。

public interface ExecutorService extends Executor {

    <T> Future<T> submit(Callable<T> task);
  
    <T> Future<T> submit(Runnable task, T result);
   
    Future<?> submit(Runnable task);
}

通过源码可以看出execute方法无返回值,参数为Runnable对象。
submit方法有三个重载方法,都有Future类型的返回值,参数可以是Runnable对象,Callable对象,Runnable对象和一个其他类型的对象。

那么在执行过程中有异常抛出会怎么样呢,先说答案,execute方法会直接抛出异常,submit方法不会抛出异常,只有在通过Future的get方法获取结果的时候才会抛出异常,下面进行测试:

public class ExecutorTest1 {

    public static void main(String[] args) {
        ExecutorService executorService = Executors.newSingleThreadExecutor();
        ExecutorTest1 test1 = new ExecutorTest1();
        executorService.execute(() -> test1.say("execute方法"));
        executorService.submit(() -> test1.say("submit方法"));
        executorService.shutdown();
    }

    private void say(String msg){
        System.out.println(msg);
        throw new RuntimeException("抛出了异常:"+ msg);
    }
}

执行结果如下:

image.png
可见execute方法直接抛出了异常,submit方法只打印了参数没有抛出异常,下面测试使用Future的get方法获取结果:

public class ExecutorTest1 {

    public static void main(String[] args) {
        ExecutorService executorService = Executors.newSingleThreadExecutor();
        ExecutorTest1 test1 = new ExecutorTest1();
        executorService.execute(() -> test1.say("execute方法"));
        Future<?> submitFuture = executorService.submit(() -> test1.say("submit方法"));
        try {
            Object o = submitFuture.get();
            System.out.println("这是submit的返回值:"+o);
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        }
        executorService.shutdown();
    }

    private void say(String msg){
        System.out.println(msg);
        throw new RuntimeException("抛出了异常:"+ msg);
    }
}

结果如下:

image.png
可见使用submit方法时只有在使用Future的get方法时才会抛出异常,并且get方法也会抛出ExecutionException异常。
那么还有一个问题,如果线程中执行方法抛出的异常已经被捕获了,那么submit会怎么处理呢,其实在方法中如果异常已经被捕获了,那么就是方法的正常运行,有异常打印的话在执行的时候就会打印,不会等到调用Future的get方法时候才会打印。测试如下:

public class ExecutorTest1 {

    public static void main(String[] args) {
        ExecutorService executorService = Executors.newSingleThreadExecutor();
        ExecutorTest1 test1 = new ExecutorTest1();
        executorService.execute(() -> test1.say("execute方法"));
        Future<?> submitFuture = executorService.submit(() -> test1.say("submit方法"));
        try {
            Object o = submitFuture.get();
            System.out.println("这是submit的返回值:"+o);
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        }
        executorService.shutdown();
    }

    private void say(String msg){
        System.out.println(msg);
        try{
            throw new RuntimeException("抛出了异常:"+ msg);
        }catch (Exception e){
            e.printStackTrace();
        }
    }
}

结果如下:

image.png
可见execute和submit都正常执行了方法,Future的get方法也获取到了结果,因为say方法没有返回值,所以打印的结果是null。

二、结论

execute和submit的区别如下:

  1. execute是Executor接口的方法,submit是ExecuteService接口的方法。
  2. execute的入参是Runnable,submit的入参可以是Runnable、Callable、Runnable和一个返回值。
  3. execute没有返回值,submit有返回值。
  4. 方法中抛出异常,execute会直接抛出异常,submit会在获取结果的时候抛出异常,如果不获取结果,submit不抛出异常。




关于Future可以查看:
Java多线程:Future和FutureTask

之前文章:

HashMap源码解析(基于JDK1.8)

Java线程池详解

标签:execute,Java,抛出,submit,Future,线程,executorService,方法
From: https://www.cnblogs.com/weiqihome/p/17082945.html

相关文章

  • Java多线程:Future和FutureTask
    一、FutureFuture是一个接口,所有方法如下:上源码:packagejava.util.concurrent;publicinterfaceFuture<V>{booleancancel(booleanmayInterruptIfRunning);......
  • 8.线程管理
    一.可靠性:线程的未捕获异常与监控 如果线程的run方法抛出未被捕获的异常,那么随着run方法的退出,相应的线程也提前终止。对于线程的这种异常终止,可以通过Thread内部定义的U......
  • 使用java python 实现 QI-页面排序-骑马钉
    链接:http://www.cnprint.org/bbs/thread/77/339531/......
  • Spring开启@Async异步方法(javaconfig配置)
    在Spring中,基于@Async标注的方法,称之为异步方法;这些方法将在执行的时候,将会在独立的线程中被执行,调用者无需等待它的完成,即可继续其他的操作。应用场景:某些耗时较长的......
  • JavaScript闭包的概念
    什么是闭包?闭包有什么作用,缺点是什么?闭包的概念:JavaScript中函数会产生闭包(closure)。闭包是函数本身和该函数声明时所处的环境状态的组合;函数能够“记忆住”其定义......
  • Java 多态
    多态就是指程序中定义的引用变量所指向的具体类型和通过该引用变量发出的方法调用在编译时并不确定,而是在程序运行期间才确定。即一个引用变量倒底会指向哪个类的实例对象......
  • 多线程知识点
    1.理论产生死锁的四个条件互斥条件:一个资源同时只能被一个线程占用请求与保持条件:一个进程因请求资源而阻塞时,对已获得资源不释放不剥夺条件:一个进程已获得的资源,在不......
  • 使用Disruptor完成多线程下并发、等待、先后等操作
    Java完成多线程间的等待功能:场景1:一个线程等待其他多个线程都完成后,再进行下一步操作(如裁判员计分功能,需要等待所有运动员都跑完后,才去统计分数。裁判员和每个运动员都是一......
  • 部署在docker里的java程序获取真实的用户ip地址
    目前我们的服务都是全部docker化,网关zuul和各微服务都部署在docker里,构成了集群。用户请求全部到HaProxy,由HaProxy转发到zuul,再由zuul分发给各微服务。那么我们在做黑名单,或......
  • Java基础系列二、代码结构+函数
    代码结构顺序结构判断结构选择结构循环结构if语句的三种格式第一种if(条件表达式){...;}...;第二种if(条件表达式){...;}else{...;}......