3年工作经验，工作中还不会使用多线程？阿里P6:别慌，我都总结好了

虽然没有结果输出，但是没有抛出异常，所以我们无法感知任务出现了异常，所以需要添加try/catch。 如下图：

OK，线程的异常处理，我们可以直接try...catch捕获。线程池exec.submit(runnable)的执行流程

通过debug上面有异常的submit方法（建议大家也去debug看一下,图上的每个方法内部是我打断点的地方），处理有异常submit方法的主要执行流程图：

//构造feature对象 
/** 
* @throws RejectedExecutionException {@inheritDoc} 
* @throws NullPointerException {@inheritDoc} 
*/ 
public Future<?> submit(Runnable task) { 
if (task == null) throw new NullPointerException(); 
RunnableFuture<Void> ftask = newTaskFor(task, null); 
execute(ftask); 
return ftask; 
} 
protected <T> RunnableFuture<T> newTaskFor(Runnable runnable, T value) { 
return new FutureTask<T>(runnable, value); 
} 
public FutureTask(Runnable runnable, V result) { 
this.callable = Executors.callable(runnable, result); 
this.state = NEW; // ensure visibility of callable 
} 
public static <T> Callable<T> callable(Runnable task, T result) { 
if (task == null) 
throw new NullPointerException(); 
return new RunnableAdapter<T>(task, result); 
} 
//线程池执行 
public void execute(Runnable command) { 
if (command == null) 
throw new NullPointerException(); 
int c = ctl.get(); 
if (workerCountOf(c) < corePoolSize) { 
if (addWorker(command, true)) 
return; 
c = ctl.get(); 
} 
if (isRunning(c) && workQueue.offer(command)) { 
int recheck = ctl.get(); 
if (! isRunning(recheck) && remove(command)) 
reject(command); 
else if (workerCountOf(recheck) == 0) 
addWorker(null, false); 
} 
else if (!addWorker(command, false)) 
reject(command); 
} 
//捕获异常 
public void run() { 
if (state != NEW || 
!UNSAFE.compareAndSwapObject(this, runnerOffset, 
null, Thread.currentThread())) 
return; 
try { 
Callable<V> c = callable; 
if (c != null && state == NEW) { 
V result; 
boolean ran; 
try { 
result = c.call(); 
ran = true; 
} catch (Throwable ex) { 
result = null; 
ran = false; 
setException(ex); 
} 
if (ran) 
set(result); 
} 
} finally { 
// runner must be non-null until state is settled to 
// prevent concurrent calls to run() 
runner = null; 
// state must be re-read after nulling runner to prevent 
// leaked interrupts 
int s = state; 
if (s >= INTERRUPTING) 
handlePossibleCancellationInterrupt(s); 
} 
制代码 

（编辑：武汉站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!