84669 Lernen von Personen
152542 Lernen von Personen
20005 Lernen von Personen
5487 Lernen von Personen
7821 Lernen von Personen
359900 Lernen von Personen
3350 Lernen von Personen
180660 Lernen von Personen
48569 Lernen von Personen
18603 Lernen von Personen
40936 Lernen von Personen
1549 Lernen von Personen
1183 Lernen von Personen
32909 Lernen von Personen
根据类的继承机构,我们知道ThreadPoolExecutorService 继承了AbstractExecutorService类继承了ExecutorService接口继承了Executor接口中的execute()方法,这个方法是被用来专门执行异步任务的,通过传入参数Runnable来执行的。但是我看到ThreadPoolExecutorService.execute(Runnable command)方法中的源码表示不理解,求大牛帮忙看看这个源码,究竟都做了一些什么?
ringa_lee
如果有小于 corePoolSize (核心线程)的线程正在执行, 就把当前任务提交到首位. 然后 addWorker 方法会做一些检查;
当新的任务放入队列之后, 还会再次执行检查(因为状态会改变或者线程池被关闭了)来判定是否需要回滚或者再创建一个新的线程对象;
如果不能把任务放入队列, 那么就会尝试添加新的 Thread 对象, 否则就会拒绝这个任务
PS: 我记得我看过一篇很不错的文章详细得分析了这个方法和整个线程池的知识, 我帮你找找...
update: 深入理解Java之线程池
加油
如果有小于 corePoolSize (核心线程)的线程正在执行, 就把当前任务提交到首位. 然后 addWorker 方法会做一些检查;
当新的任务放入队列之后, 还会再次执行检查(因为状态会改变或者线程池被关闭了)来判定是否需要回滚或者再创建一个新的线程对象;
如果不能把任务放入队列, 那么就会尝试添加新的 Thread 对象, 否则就会拒绝这个任务
PS: 我记得我看过一篇很不错的文章详细得分析了这个方法和整个线程池的知识, 我帮你找找...
update: 深入理解Java之线程池
加油