線程池的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);
    }
}

 

 

  


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM