面试官：你分析过线程池源码吗？

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了面试官：你分析过线程池源码吗？，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含13772字，纯文字阅读大概需要20分钟。

内容图文

为什么要用线程池?

简洁的答两点就行。

降低系统资源消耗。
提高线程可控性。

如何创建使用线程池?

JDK8提供了五种创建线程池的方法：

1.创建一个定长线程池，可控制线程最大并发数，超出的线程会在队列中等待。

public?static?ExecutorService?newFixedThreadPool(int?nThreads)?{
????return?new?ThreadPoolExecutor(nThreads,?nThreads,
??????????????????????????????????0L,?TimeUnit.MILLISECONDS,
??????????????????????????????????new?LinkedBlockingQueue<Runnable>());
}

2.(JDK8新增)会根据所需的并发数来动态创建和关闭线程。能够合理的使用CPU进行对任务进行并发操作，所以适合使用在很耗时的任务。

注意返回的是ForkJoinPool对象。

public?static?ExecutorService?newWorkStealingPool(int?parallelism)?{
????return?new?ForkJoinPool
????????(parallelism,
?????????ForkJoinPool.defaultForkJoinWorkerThreadFactory,
?????????null,?true);
}

什么是ForkJoinPool：

public?ForkJoinPool(int?parallelism,
????????????????????????ForkJoinWorkerThreadFactory?factory,
????????????????????????UncaughtExceptionHandler?handler,
????????????????????????boolean?asyncMode)?{
????????this(checkParallelism(parallelism),
?????????????checkFactory(factory),
?????????????handler,
?????????????asyncMode???FIFO_QUEUE?:?LIFO_QUEUE,
?????????????"ForkJoinPool-"?+?nextPoolId()?+?"-worker-");
????????checkPermission();
????}

使用一个无限队列来保存需要执行的任务，可以传入线程的数量；不传入，则默认使用当前计算机中可用的cpu数量；使用分治法来解决问题，使用fork()和join()来进行调用。

3.创建一个可缓存的线程池,可灵活回收空闲线程，若无可回收，则新建线程。

public?static?ExecutorService?newCachedThreadPool()?{
????return?new?ThreadPoolExecutor(0,?Integer.MAX_VALUE,
??????????????????????????????????60L,?TimeUnit.SECONDS,
??????????????????????????????????new?SynchronousQueue<Runnable>());
}

4.创建一个单线程的线程池。

public?static?ExecutorService?newSingleThreadExecutor()?{
????return?new?FinalizableDelegatedExecutorService
????????(new?ThreadPoolExecutor(1,?1,
????????????????????????????????0L,?TimeUnit.MILLISECONDS,
????????????????????????????????new?LinkedBlockingQueue<Runnable>()));
}

5.创建一个定长线程池，支持定时及周期性任务执行。

public?static?ScheduledExecutorService?newScheduledThreadPool(int?corePoolSize)?{
????return?new?ScheduledThreadPoolExecutor(corePoolSize);
}

上层源码结构分析

Executor结构:

面试官：你分析过线程池源码吗？ - 文章图片

Executor

一个运行新任务的简单接口

public?interface?Executor?{

????void?execute(Runnable?command);
}

ExecutorService

扩展了Executor接口。添加了一些用来管理执行器生命周期和任务生命周期的方法

面试官：你分析过线程池源码吗？ - 文章图片

AbstractExecutorService

对ExecutorService接口的抽象类实现。不是我们分析的重点。

ThreadPoolExecutor

Java线程池的核心实现。

ThreadPoolExecutor源码分析

属性解释

//?AtomicInteger是原子类??ctlOf()返回值为RUNNING；
private?final?AtomicInteger?ctl?=?new?AtomicInteger(ctlOf(RUNNING,?0));
//?高3位表示线程状态
private?static?final?int?COUNT_BITS?=?Integer.SIZE?-?3;
//?低29位表示workerCount容量
private?static?final?int?CAPACITY???=?(1?<<?COUNT_BITS)?-?1;

//?runState?is?stored?in?the?high-order?bits
//?能接收任务且能处理阻塞队列中的任务
private?static?final?int?RUNNING????=?-1?<<?COUNT_BITS;
//?不能接收新任务，但可以处理队列中的任务。
private?static?final?int?SHUTDOWN???=??0?<<?COUNT_BITS;
//?不接收新任务，不处理队列任务。
private?static?final?int?STOP???????=??1?<<?COUNT_BITS;
//?所有任务都终止
private?static?final?int?TIDYING????=??2?<<?COUNT_BITS;
//?什么都不做
private?static?final?int?TERMINATED?=??3?<<?COUNT_BITS;

//?存放任务的阻塞队列
private?final?BlockingQueue<Runnable>?workQueue;

值的注意的是状态值越大线程越不活跃。

线程池状态的转换模型：

构造器

public?ThreadPoolExecutor(int?corePoolSize,//线程池初始启动时线程的数量
??????????????????????????int?maximumPoolSize,//最大线程数量
??????????????????????????long?keepAliveTime,//空闲线程多久关闭?
??????????????????????????TimeUnit?unit,//?计时单位
??????????????????????????BlockingQueue<Runnable>?workQueue,//放任务的阻塞队列
??????????????????????????ThreadFactory?threadFactory,//线程工厂
??????????????????????????RejectedExecutionHandler?handler//?拒绝策略)?{
????if?(corePoolSize?<?0?||
????????maximumPoolSize?<=?0?||
????????maximumPoolSize?<?corePoolSize?||
????????keepAliveTime?<?0)
????????throw?new?IllegalArgumentException();
????if?(workQueue?==?null?||?threadFactory?==?null?||?handler?==?null)
????????throw?new?NullPointerException();
????this.acc?=?System.getSecurityManager()?==?null??
????????????null?:
????????????AccessController.getContext();
????this.corePoolSize?=?corePoolSize;
????this.maximumPoolSize?=?maximumPoolSize;
????this.workQueue?=?workQueue;
????this.keepAliveTime?=?unit.toNanos(keepAliveTime);
????this.threadFactory?=?threadFactory;
????this.handler?=?handler;
}

在向线程池提交任务时，会通过两个方法：execute和submit。

本文着重讲解execute方法。submit方法放在下次和Future、Callable一起分析。

execute方法:

public?void?execute(Runnable?command)?{
????if?(command?==?null)
????????throw?new?NullPointerException();
????//?clt记录着runState和workerCount
????int?c?=?ctl.get();
????//workerCountOf方法取出低29位的值，表示当前活动的线程数
????//然后拿线程数和?核心线程数做比较
????if?(workerCountOf(c)?<?corePoolSize)?{
????????//?如果活动线程数<核心线程数
????????//?添加到
????????//addWorker中的第二个参数表示限制添加线程的数量是根据corePoolSize来判断还是maximumPoolSize来判断
????????if?(addWorker(command,?true))
????????????//?如果成功则返回
????????????return;
????????//?如果失败则重新获取?runState和?workerCount
????????c?=?ctl.get();
????}
????//?如果当前线程池是运行状态并且任务添加到队列成功
????if?(isRunning(c)?&&?workQueue.offer(command))?{
????????//?重新获取?runState和?workerCount
????????int?recheck?=?ctl.get();
????????//?如果不是运行状态并且?
????????if?(!?isRunning(recheck)?&&?remove(command))
????????????reject(command);
????????else?if?(workerCountOf(recheck)?==?0)
????????????//第一个参数为null，表示在线程池中创建一个线程，但不去启动
????????????//?第二个参数为false，将线程池的有限线程数量的上限设置为maximumPoolSize
????????????addWorker(null,?false);
????}
????//再次调用addWorker方法，但第二个参数传入为false，将线程池的有限线程数量的上限设置为maximumPoolSize
????else?if?(!addWorker(command,?false))
????????//如果失败则拒绝该任务
????????reject(command);
}

总结一下它的工作流程：

当workerCount < corePoolSize，创建线程执行任务。
当workerCount >= corePoolSize&&阻塞队列workQueue未满，把新的任务放入阻塞队列。
当workQueue已满，并且workerCount >= corePoolSize，并且workerCount < maximumPoolSize，创建线程执行任务。
当workQueue已满，workerCount >= maximumPoolSize，采取拒绝策略,默认拒绝策略是直接抛异常。

通过上面的execute方法可以看到，最主要的逻辑还是在addWorker方法中实现的，那我们就看下这个方法：

addWorker方法

主要工作是在线程池中创建一个新的线程并执行

参数定义：

firstTask the task the new thread should run first (or null if none). (指定新增线程执行的第一个任务或者不执行任务)
core if true use corePoolSize as bound, else maximumPoolSize.(core如果为true则使用corePoolSize绑定，否则为maximumPoolSize。（此处使用布尔指示符而不是值，以确保在检查其他状态后读取新值）。)

private?boolean?addWorker(Runnable?firstTask,?boolean?core)?{
????retry:
????for?(;;)?{

????????int?c?=?ctl.get();
????????//??获取运行状态
????????int?rs?=?runStateOf(c);

????????//?Check?if?queue?empty?only?if?necessary.
????????//?如果状态值?>=?SHUTDOWN?(不接新任务&不处理队列任务)
????????//?并且?如果?！(rs为SHUTDOWN?且?firsTask为空?且?阻塞队列不为空)
????????if?(rs?>=?SHUTDOWN?&&
????????????!?(rs?==?SHUTDOWN?&&
???????????????firstTask?==?null?&&
???????????????!?workQueue.isEmpty()))
????????????//?返回false
????????????return?false;

????????for?(;;)?{
????????????//获取线程数wc
????????????int?wc?=?workerCountOf(c);
????????????//?如果wc大与容量?||?core如果为true表示根据corePoolSize来比较,否则为maximumPoolSize
????????????if?(wc?>=?CAPACITY?||
????????????????wc?>=?(core???corePoolSize?:?maximumPoolSize))
????????????????return?false;
????????????//?增加workerCount（原子操作）
????????????if?(compareAndIncrementWorkerCount(c))
????????????????//?如果增加成功，则跳出
????????????????break?retry;
????????????//?wc增加失败，则再次获取runState
????????????c?=?ctl.get();??//?Re-read?ctl
????????????//?如果当前的运行状态不等于rs，说明状态已被改变，返回重新执行
????????????if?(runStateOf(c)?!=?rs)
????????????????continue?retry;
????????????//?else?CAS?failed?due?to?workerCount?change;?retry?inner?loop
????????}
????}

????boolean?workerStarted?=?false;
????boolean?workerAdded?=?false;
????Worker?w?=?null;
????try?{
????????//?根据firstTask来创建Worker对象
????????w?=?new?Worker(firstTask);
????????//?根据worker创建一个线程
????????final?Thread?t?=?w.thread;
????????if?(t?!=?null)?{
????????????//?new一个锁
????????????final?ReentrantLock?mainLock?=?this.mainLock;
????????????//?加锁
????????????mainLock.lock();
????????????try?{
????????????????//?Recheck?while?holding?lock.
????????????????//?Back?out?on?ThreadFactory?failure?or?if
????????????????//?shut?down?before?lock?acquired.
????????????????//?获取runState
????????????????int?rs?=?runStateOf(ctl.get());
????????????????//?如果rs小于SHUTDOWN(处于运行)或者(rs=SHUTDOWN?&&?firstTask?==?null)
????????????????//?firstTask?==?null证明只新建线程而不执行任务
????????????????if?(rs?<?SHUTDOWN?||
????????????????????(rs?==?SHUTDOWN?&&?firstTask?==?null))?{
????????????????????//?如果t活着就抛异常
????????????????????if?(t.isAlive())?//?precheck?that?t?is?startable
????????????????????????throw?new?IllegalThreadStateException();
????????????????????//?否则加入worker(HashSet)
????????????????????//workers包含池中的所有工作线程。仅在持有mainLock时访问。
????????????????????workers.add(w);
????????????????????//?获取工作线程数量
????????????????????int?s?=?workers.size();
????????????????????//largestPoolSize记录着线程池中出现过的最大线程数量
????????????????????if?(s?>?largestPoolSize)
????????????????????????//?如果?s比它还要大，则将s赋值给它
????????????????????????largestPoolSize?=?s;
????????????????????//?worker的添加工作状态改为true????
????????????????????workerAdded?=?true;
????????????????}
????????????}?finally?{
????????????????mainLock.unlock();
????????????}
????????????//?如果worker的添加工作完成
????????????if?(workerAdded)?{
????????????????//?启动线程
????????????????t.start();
????????????????//?修改线程启动状态
????????????????workerStarted?=?true;
????????????}
????????}
????}?finally?{
????????if?(!?workerStarted)
????????????addWorkerFailed(w);
????}
????//?返回线启动状态
????return?workerStarted;

为什么需要持有mainLock？

因为workers是HashSet类型的，不能保证线程安全。

那w = new Worker(firstTask);如何理解呢

Worker.java

private?final?class?Worker
????extends?AbstractQueuedSynchronizer
????implements?Runnable

可以看到它继承了AQS并发框架还实现了Runnable。证明它还是一个线程任务类。那我们调用t.start()事实上就是调用了该类重写的run方法。

Worker为什么不使用ReentrantLock来实现呢？

tryAcquire方法它是不允许重入的，而ReentrantLock是允许重入的。对于线程来说，如果线程正在执行是不允许其它锁重入进来的。

线程只需要两个状态，一个是独占锁，表明正在执行任务；一个是不加锁，表明是空闲状态。

public?void?run()?{
????runWorker(this);
}

run方法又调用了runWorker方法：

final?void?runWorker(Worker?w)?{
????//?拿到当前线程
????Thread?wt?=?Thread.currentThread();
????//?拿到当前任务
????Runnable?task?=?w.firstTask;
????//?将Worker.firstTask置空?并且释放锁
????w.firstTask?=?null;
????w.unlock();?//?allow?interrupts
????boolean?completedAbruptly?=?true;
????try?{
????????//?如果task或者getTask不为空，则一直循环
????????while?(task?!=?null?||?(task?=?getTask())?!=?null)?{
????????????//?加锁
????????????w.lock();
????????????//?If?pool?is?stopping,?ensure?thread?is?interrupted;
????????????//?if?not,?ensure?thread?is?not?interrupted.??This
????????????//?requires?a?recheck?in?second?case?to?deal?with
????????????//?shutdownNow?race?while?clearing?interrupt
????????????//??return?ctl.get()?>=?stop?
????????????//?如果线程池状态>=STOP?或者?(线程中断且线程池状态>=STOP)且当前线程没有中断
????????????//?其实就是保证两点：
????????????//?1.?线程池没有停止
????????????//?2.?保证线程没有中断
????????????if?((runStateAtLeast(ctl.get(),?STOP)?||
?????????????????(Thread.interrupted()?&&
??????????????????runStateAtLeast(ctl.get(),?STOP)))?&&
????????????????!wt.isInterrupted())
????????????????//?中断当前线程
????????????????wt.interrupt();
????????????try?{
????????????????//?空方法
????????????????beforeExecute(wt,?task);
????????????????Throwable?thrown?=?null;
????????????????try?{
????????????????????//?执行run方法(Runable对象)
????????????????????task.run();
????????????????}?catch?(RuntimeException?x)?{
????????????????????thrown?=?x;?throw?x;
????????????????}?catch?(Error?x)?{
????????????????????thrown?=?x;?throw?x;
????????????????}?catch?(Throwable?x)?{
????????????????????thrown?=?x;?throw?new?Error(x);
????????????????}?finally?{
????????????????????afterExecute(task,?thrown);
????????????????}
????????????}?finally?{
????????????????//?执行完后，?将task置空，?完成任务++，?释放锁
????????????????task?=?null;
????????????????w.completedTasks++;
????????????????w.unlock();
????????????}
????????}
????????completedAbruptly?=?false;
????}?finally?{
????????//?退出工作
????????processWorkerExit(w,?completedAbruptly);
????}

总结一下runWorker方法的执行过程：

while循环中，不断地通过getTask()方法从workerQueue中获取任务
如果线程池正在停止，则中断线程。否则调用3.
调用task.run()执行任务；
如果task为null则跳出循环，执行processWorkerExit()方法，销毁线程workers.remove(w);

这个流程图非常经典：

面试官：你分析过线程池源码吗？ - 文章图片

除此之外，ThreadPoolExector还提供了tryAcquire、tryRelease、shutdown、shutdownNow、tryTerminate、等涉及的一系列线程状态更改的方法有兴趣可以自己研究。大体思路是一样的，这里不做介绍。

Worker为什么不使用ReentrantLock来实现呢？

tryAcquire方法它是不允许重入的，而ReentrantLock是允许重入的。对于线程来说，如果线程正在执行是不允许其它锁重入进来的。

线程只需要两个状态，一个是独占锁，表明正在执行任务；一个是不加锁，表明是空闲状态。

在runWorker方法中，为什么要在执行任务的时候对每个工作线程都加锁呢？

shutdown方法与getTask方法存在竞态条件.(这里不做深入，建议自己深入研究，对它比较熟悉的面试官一般会问)

高频考点

创建线程池的五个方法。
线程池的五个状态
execute执行过程。
runWorker执行过程。(把两个流程图记下，理解后说个大该就行。)

内容总结

以上是互联网集市为您收集整理的面试官：你分析过线程池源码吗？全部内容，希望文章能够帮你解决面试官：你分析过线程池源码吗？所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/834907.html

来源：【匿名】

【上一篇】金三银四背后，一个JAVA程序员的面试心得【下一篇】色色整理的PHP面试题集锦

更多 ►

【面试官：你分析过线程池源码吗？】教程文章相关的互联网学习教程文章

java线程面试题1.实现线程的方法，有什么区别继承Thread与实现Runnable接口。启动方法不一样。Thread1继承，Thread2实现Runnable接口，则启动一个Thread1线程可以使用new Thread1().start(),而启动Thread2线程则newThread(new Thread2()).start()。 2.可以使用run方法启动一个线程吗？启动一个线程应该使用start方法，线程的run方法可以直接调用，但是不会启动一个新的线程，只是在原来的线程中调用了run方法而已。3.sleep方法与...

多线程面试题-sleep()和wait()区别

sleep(): 1 .是Thread类中的一个方法,用于线程休眠, 2 .休眠时间结束后，该线程可以自动唤醒；wait(): 1. 是Object类中的一个方法,用于线程等待， 2. 如果想要唤醒,必须使用notify()或notifyAll(),(不能自动唤醒)原文：http://www.cnblogs.com/yuefeng123/p/7465921.html

面试之线程【代码】

一、JDK、JRE和JVM三者之间关系：　　1、所有的JAVA程序都会被编译成class文件，由虚拟机JVM和操作系统交互2、JVM需要调用解释所需要的类库lib才可以执行class文件，JVM+lib=JRE即JAVA运行环境3、JDK主要用于程序开发，最主要是编译器，包含了JRE，JAVA工具类和JAVA基础类库二、怎么实现线程实现Runnable接口或者继承Thread类来实现，当你打算多重继承时，优先选择实现Runnable三、Thread.start()与Thread.run()有什么区别调用sta...

秒杀多线程第一篇多线程笔试面试题汇总

原文：http://blog.csdn.net/morewindows/article/details/7392749系列前言本系列是本人参加微软亚洲研究院，腾讯研究院，迅雷面试时整理的，另外也加入一些其它IT公司如百度，阿里巴巴的笔试面试题目，因此具有很强的针对性。系列中不但会详细讲解多线程同步互斥的各种“招式”，而且会进一步的讲解多线程同步互斥的“内功心法”。有了“招式”和“内功心法”，相信你也能对多线程挥洒自如，在笔试面试中顺利的秒杀多线程试题...

多线程面试题（2020）

多线程 1.并行和并发有什么区别？并行：多个任务在同一个 CPU 核上，按细分的时间片轮流(交替)执行，从逻辑上来看那些任务是同时执行。并发：多个处理器或多核处理器同时处理多个任务。如下图：并发和并行并发 = 两个队列和一台咖啡机。并行 = 两个队列和两台咖啡机。 2.线程和进程的区别？一个程序下至少有一个进程，一个进程下至少有一个线程，一个进程下也可以有多个线程来增加程序的执行速度。3.守护线程是什么？守...

多线程访问同步方法的7种情况（面试常考）【图】

1.2.34.同时访问同步方法和非同步方法synchronized只作用于用它修饰的方法，没有加synchronized 的方法不会受到影响，如图可以看出加了synchronized修饰符的方法和没有加的方法是同步执行的，也就是说互不影响 5.同时访问一个类的普通同步方法对于同一个实例来说，他们拿到了同一把锁，没办法同时运行，而是串行*虽然synchronized没有指明用那一把锁，但是其背后原理已经指明他们用了同一把锁，因为他们用了同一把锁* 同一个实例 ...

秒杀多线程面试题系列

【专栏】- 秒杀多线程面试题系列 - MoreWindows Blog（格物穷理，以求自由！） - CSDN博客 PV原语操作详解 - Benson_xiong - 博客园原文：https://www.cnblogs.com/zhehan54/p/10053582.html

Android多线程研究（4）——从一道面试题说起【图】

有一道这样的面试题：开启一个子线程和主线程同时运行，子线程输出10次后接着主线程输出100次，如此反复50次。先看下面代码：package com.maso.test;/*** * @author Administrator* 两个线程，其中是一个主线程，第一个线程先运行输出10次，主线程接着运行输出100次，如此反复50次*/ public class ThreadTest3 implements Runnable{private static Test test;@Overridepublic void run() {for(int i=0; i<50; i++){test.f1(i);}}pu...

Android多线程研究（4）——从一道面试题说起【图】

有一道这种面试题：开启一个子线程和主线程同一时候运行，子线程输出10次后接着主线程输出100次，如此重复50次。先看以下代码：package com.maso.test;/*** * @author Administrator* 两个线程，当中是一个主线程，第一个线程先运行输出10次，主线程接着运行输出100次，如此重复50次*/ public class ThreadTest3 implements Runnable{private static Test test;@Overridepublic void run() {for(int i=0; i<50; i++){test.f1(i);}}...

JAVA学习第二十八课（多线程（七））- 停止线程和多线程面试题

重点掌握/* * wait 和 sleep 区别？ * 1.wait可以指定时间也可以不指定 * sleep必须指定时间 * 2.在同步中，对CPU的执行权和锁的处理不同 * wait释放执行权，释放锁 sleep释放执行权，不释放锁 *///同步里具备执行资格的线程不止一个，但是能得到锁的只有一个，所以能执行的也只有一个一、停止线程的方式不可能让线程一直在运行，所以需要让线程停止1.定义循环结束标记一般而言，线程运行代码都是循环的，只要控制了循环就...

面试官: 什么是 Hook (钩子) 线程以及应用场景?【代码】【图】

一、Hook 线程介绍通常情况下，我们可以向应用程序注入一个或多个 Hook (钩子) 线程，这样，在程序即将退出的时候，也就是 JVM 程序即将退出的时候，Hook 线程就会被启动执行。先看一段示例代码：①：为应用程序注入一个钩子（Hook）线程，线程中，打印了相关日志，包括正在运行以及退出的日志；②：再次注入一个同样逻辑的钩子（Hook）线程；③：主线程执行结束，打印日志；运行这段代码，来验证一下：从打印日志看到，当主线程执...

java线程基础巩固---wait和sleep的本质区别是什么，深入分析（面试常见问题）【图】

对于wait和sleep貌似都会阻塞线程，但是它们确实是很大的区别的，所以下面一点点来探讨：区别一、Sleep()是线程里面的方法，而Wait()是Object类的方法。这个比较简单，直接看代码便知：区别二、sleep()方法不需要被notify唤醒，而wait()则需要【当然wait(10)这样的情况除外】。这个比较容易理解，就不多解释了。sleep()使用是不需要使用syncronized加上同步锁，但是wait()需要。这个做一下实验就明白了：嗯~~调用sleep()时是不需要...

面试题-实现多线程的方式【代码】【图】

Java中实现多线程的方式有下面三种：继承Thread类，重写run方法package fs;public class ThreadTest {public static void main(String[] args) {new MyThread().start();} }class MyThread extends Thread {@Overridepublic void run() {System.out.println("我是一个线程，我叫："+Thread.currentThread().getName());} }实现Runnable接口，重写run方法package fs;public class ThreadTest {public static void main(String[] arg...

Java面试：投行的15个多线程和并发面试题【图】

多线程和并发问题已成为各种 Java 面试中必不可少的一部分。如果你准备参加投行的 Java 开发岗位面试，比如巴克莱银行（Barclays）、花旗银行（Citibank）、摩根史坦利投资公司（Morgan Stanley），你会遇到很多有关多线程的面试题。多线程和并发是投行面试的热门知识点，尤其是在面试有关电子交易开发工作时，他们喜欢用棘手的 Java 线程面试题轰炸面试者。他们希望确保面试者对 Java 多线程和并发有扎实的知识基础，因为他们大多...

2019Android多线程面试总结【代码】【图】

极力推荐文章：欢迎收藏Android 干货分享阅读五分钟，每日十点，和您一起终身学习，这里是程序员Android1.什么是线程线程就是进程中运行的多个子任务，是操作系统调用的最小单元2.线程的状态1.New:新建状态，new出来，还没有调用start2.Runnable:可运行状态，调用start进入可运行状态，可能运行也可能没有运行，取决于操作系统的调度3.Blocked:阻塞状态，被锁阻塞，暂时不活动，阻塞状态是线程阻塞在进入4.synchronized:关键字修饰...

面试 - 相关标签

面试总结

面试 - 最热教程

10个最常见的HTML5面试题及答案 Netty面试题（2020）java各公司面试记录 Android 开发面试题集合整理（内含答案...4轮字节面试后杳无音信，自己是在了备胎...Java面试题分享 php面试题五之nginx如何调用php和php-f...安卓rxjava使用，Android性能优化面试题...Java 面试——Zookeeper android逆向！Android开发岗还不会这些...

首页 / 面试 / 面试官：你分析过线程池源码吗？

面试官：你分析过线程池源码吗？

内容导读

内容图文

为什么要用线程池?

如何创建使用线程池?

JDK8提供了五种创建线程池的方法：

上层源码结构分析

Executor

ExecutorService

AbstractExecutorService

ThreadPoolExecutor

ThreadPoolExecutor源码分析

属性解释

线程池状态的转换模型：

构造器

execute方法:

addWorker方法

为什么需要持有mainLock？

Worker.java

Worker为什么不使用ReentrantLock来实现呢？

Worker为什么不使用ReentrantLock来实现呢？

在runWorker方法中，为什么要在执行任务的时候对每个工作线程都加锁呢？

高频考点

内容总结

内容备注

内容手机端

【面试官：你分析过线程池源码吗？】教程文章相关的互联网学习教程文章

面试 - 相关标签

面试 - 最新教程

面试 - 最热教程