在ExecutorService's提交和ExecutorService's执行之间进行选择

摘自Javadoc:

方法submit通过创建和扩展基方法{@link Executor#execute} 返回一个{@link Future}，可用于取消执行和/或等待 完成。< / p >

就我个人而言，我更喜欢使用execute，因为它感觉更具有声明性，尽管这确实是个人偏好的问题。

提供更多信息:在ExecutorService实现的情况下，调用Executors.newSingleThreadedExecutor()返回的核心实现是ThreadPoolExecutor。

submit调用由其父AbstractExecutorService提供，所有调用都在内部执行。execute被ThreadPoolExecutor直接覆盖/提供。

如果你不关心返回类型，使用execute。它和submit一样，只是没有Future的返回。

在异常/错误处理方面有区别。

与execute()一起排队并生成一些Throwable的任务将导致运行该任务的Thread的UncaughtExceptionHandler被调用。如果没有安装自定义处理程序，将调用默认的UncaughtExceptionHandler，它通常将Throwable堆栈跟踪打印到System.err。

另一方面，由带有submit()队列的任务生成的Throwable将把Throwable绑定到调用submit()产生的Future。在该Future上调用get()将抛出一个以原始Throwable为起因的ExecutionException(可通过在ExecutionException上调用getCause()来访问)。

从Javadoc:

该命令可以在新线程、池线程或调用线程中执行，由Executor实现自行决定。

因此，根据Executor的实现，你可能会发现提交线程在任务执行时阻塞。

< em > < / em >执行:用于火灾和忘记呼叫

< em > < / em >提交:使用它检查方法调用的结果，并对调用返回的Future对象采取适当的操作

从javadocs

submit(Callable<T> task)

提交一个返回值的任务来执行，并返回一个Future

.

.

.

Future<?> submit(Runnable task)

提交一个可运行任务以供执行，并返回表示该任务的Future 任务。< / p >

void execute(Runnable command)

在将来的某个时间执行给定的命令。该命令可以在新线程、池线程或调用线程中执行，由Executor实现自行决定。

在使用submit()时必须采取预防措施。除非你在try{} catch{}块中嵌入你的任务代码，否则它会在框架本身中隐藏异常。

此代码包含Arithmetic exception : / by zero。

import java.util.concurrent.*;
import java.util.*;


public class ExecuteSubmitDemo{
public ExecuteSubmitDemo()
{
System.out.println("creating service");
ExecutorService service = Executors.newFixedThreadPool(10);
//ExtendedExecutor service = new ExtendedExecutor();
service.submit(new Runnable(){
public void run(){
int a=4, b = 0;
System.out.println("a and b="+a+":"+b);
System.out.println("a/b:"+(a/b));
System.out.println("Thread Name in Runnable after divide by zero:"+Thread.currentThread().getName());
}
});
service.shutdown();
}
public static void main(String args[]){
ExecuteSubmitDemo demo = new ExecuteSubmitDemo();
}
}

输出:

java ExecuteSubmitDemo
creating service
a and b=4:0

用execute()替换submit()会抛出相同的代码:

取代

service.submit(new Runnable(){

与

service.execute(new Runnable(){

输出:

java ExecuteSubmitDemo
creating service
a and b=4:0
Exception in thread "pool-1-thread-1" java.lang.ArithmeticException: / by zero
at ExecuteSubmitDemo$1.run(ExecuteSubmitDemo.java:14)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:744)

如何处理这些类型的场景，而使用submit()?< / em >

import java.util.concurrent.*;
import java.util.*;


public class ExecuteSubmitDemo{
public ExecuteSubmitDemo()
{
System.out.println("creating service");
//ExecutorService service = Executors.newFixedThreadPool(10);
ExtendedExecutor service = new ExtendedExecutor();
service.submit(new Runnable(){
public void run(){
int a=4, b = 0;
System.out.println("a and b="+a+":"+b);
System.out.println("a/b:"+(a/b));
System.out.println("Thread Name in Runnable after divide by zero:"+Thread.currentThread().getName());
}
});
service.shutdown();
}
public static void main(String args[]){
ExecuteSubmitDemo demo = new ExecuteSubmitDemo();
}
}


class ExtendedExecutor extends ThreadPoolExecutor {


public ExtendedExecutor() {
super(1,1,60,TimeUnit.SECONDS,new ArrayBlockingQueue<Runnable>(100));
}
// ...
protected void afterExecute(Runnable r, Throwable t) {
super.afterExecute(r, t);
if (t == null && r instanceof Future<?>) {
try {
Object result = ((Future<?>) r).get();
} catch (CancellationException ce) {
t = ce;
} catch (ExecutionException ee) {
t = ee.getCause();
} catch (InterruptedException ie) {
Thread.currentThread().interrupt(); // ignore/reset
}
}
if (t != null)
System.out.println(t);
}
}

java ExecuteSubmitDemo
creating service
a and b=4:0
java.lang.ArithmeticException: / by zero