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); 
} 
制代码 

（编辑：湖南网）

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