zoukankan      html  css  js  c++  java
  • 线程池的submit和execute方法区别

    线程池中的execute方法大家都不陌生,即开启线程执行池中的任务。还有一个方法submit也可以做到,它的功能是提交指定的任务去执行并且返回Future对象,即执行的结果。下面简要介绍一下两者的三个区别:

    1、接收的参数不一样

    public class MainTest {
    
        public static void main(String[] args) throws Exception {
            ExecutorService pool = Executors.newFixedThreadPool(10);
            pool.execute(new Runnable() {
                @Override
                public void run() {
                    System.out.println("execute");
                }
            });
    
            Future<?> submit = pool.submit(new Runnable() {
                @Override
                public void run() {
                    System.out.println("submit");
                }
            });
            //等任务执行完毕会打印null
            System.out.println(submit.get());
    
            FutureTask<Integer> submit2 = (FutureTask<Integer>) pool.submit(new Callable<Integer>() {
                @Override
                public Integer call() throws Exception {
                    System.out.println("submit_2");
                    return 2;
                }
            });
            System.out.println("result=" + submit2.get());
        }
    
    }

    2、submit有返回值,而execute没有

    用到返回值的例子,比如说我有很多个做validation的task,我希望所有的task执行完,然后每个task告诉我它的执行结果,是成功还是失败,如果是失败,原因是什么。
    然后我就可以把所有失败的原因综合起来发给调用者。

    个人觉得cancel execution这个用处不大,很少有需要去取消执行的。

    而最大的用处应该是第二点。
    3、submit方便Exception处理
    意思就是如果你在你的task里会抛出checked或者unchecked exception,
    而你又希望外面的调用者能够感知这些exception并做出及时的处理,那么就需要用到submit,通过捕获Future.get抛出的异常。

    下面一个小程序演示一下submit方法 

    /**
     * @author WGR
     * @create 2020/5/7 -- 0:08
     */
    public class RunnableTestMain {
    
        public static void main(String[] args) {
            ExecutorService pool = Executors.newFixedThreadPool(2);
    
            /**
             * execute(Runnable x) 没有返回值。可以执行任务,但无法判断任务是否成功完成。
             */
            pool.execute(new RunnableTest("Task1"));
    
            /**
             * submit(Runnable x) 返回一个future。可以用这个future来判断任务是否成功完成。请看下面:
             */
            Future future = pool.submit(new RunnableTest("Task2"));
    
            try {
                if(future.get()==null){//如果Future's get返回null,任务完成
                    System.out.println("任务完成");
                }
            } catch (InterruptedException e) {
            } catch (ExecutionException e) {
                //否则我们可以看看任务失败的原因是什么
                System.out.println(e.toString());
            }
    
        }
    
    }
    
    class RunnableTest implements Runnable {
    
        private String taskName;
    
        public RunnableTest(final String taskName) {
            this.taskName = taskName;
        }
    
        @Override
        public void run() {
            System.out.println("Inside " + taskName);
            throw new RuntimeException("RuntimeException from inside " + taskName);
        }
    }
    

      

  • 相关阅读:
    WordPress修改后台登录地址
    android开发之浅谈viewpager
    android开发之viewpager and Fragment
    android开发之 广播机制
    android开发之 SQLite(数据库)
    前端目标——天猫网页
    android 开发之Toast
    centos8 单机安装k8s
    mysql 查看库大小
    idea 常见问题
  • 原文地址:https://www.cnblogs.com/dalianpai/p/12840107.html
Copyright © 2011-2022 走看看