【你问我答】这些Java并发问题,专家是这么回答的

针对上期Java高并发【你问我答】中读者提出的问题,王锐同学的回答如下。


美团内部使用过Akka么?有什么坑?

——Absurd

答:

只简单用过Akka,Akka cluster没用过。

1. actor里面最好不要有阻塞操作,如果有的话一定要设置下dispatcher。 2. 监控好邮箱队列长度,最简单的做法就是原子变量记录。 3. 如果一直创建新actor,会有内存泄露;必要时可缓存,或者调用stop方法。 目前我们系统应用了Akka,系统比较稳定。


在分布式、微服务的大环境下,Java并发还有学习的必要吗?不都是Redis以及ZooKeeper的分布式锁吗?也都是集群部署的形式。

——james.yue

答:

并发编程所包含的不仅仅是锁,其实包含了4层含义:

① 内存模型和一致性协议;

② 锁相关包括自旋锁、死锁、活锁等理论;

③ 无锁的数据结构;

④ 各个语言的并发模型。

一般的并发基础都是基于单机的,但是基础理论的强大之处在于它可以影响你在系统设计时候的取舍,比如分布式锁也需要考虑是否重入、阻塞中断、超时唤醒、失效取消等等问题,而不是简单的使用ZooKeeper或者Redis就能完美解决的。

计算机世界没有银弹。


ReentrantLock和Synchronized之间怎么选择?

——我木有名字

答:

1.6以前Synchronized实现稍显笨重,所以如果你是1.6以前的JDK并且是中等程度的并发,请使用ReentrantLock。如果并发很高,ReentrantLock的CAS机制会带来一定的CPU浪费,那么Synchronized更好。1.6以后,Synchronized做了大量的优化,所以在没有特殊功能要求的情况下(比如你需要中断锁或者tryLock或者读写锁或者公平锁等)推荐使用Synchronized,特殊需求使用ReentrantLock这个一系列的工具。


队列的拒绝机制。

——落拓书生

答:

因为不确定是哪种队列,所以没办法说的很细,一般的队列拒绝策略有以下几种:拒绝最新的,就是最后请求加入队列的直接丢弃;拒绝最老的,就是把队列头部的拒绝;新请求加入的可以入队;随机拒绝,就是兼容上面二者。


请详细介绍一下Java 8中ConcurrentHashMap的原理。

——不告诉你

答:

这个问题太大了,说一些关键点吧,网上也有很多的源码分析,就不赘述了:

① 摒弃了Segment(锁段)的概念,而是启用了一种全新的方式实现,利用CAS算法。因为原有的分段锁在扩容以及并发度调整的时候会同时锁住多个锁(每个段一个锁),这样容易造成死锁以及极大的性能损耗。

② Hash算法优化,这个和HashMap是一致的,为了解决在key冲突多的时候退化成链表的问题。

③ 大量应用CAS方法进行变量、属性的修改工作。利用CAS进行无锁操作,可以大大提高性能。


实际工作当中不太接触并发的知识,但是面试的时候问的最多的是并发,如何破解?

——凌亂

答:

面试过程中更多是对知识的考察,并没有太多深入的实际使用,所以只需要去学习就OK了。

学习并发有4个方面:

① 内存模型和一致性协议

② 锁相关包括自旋锁、死锁、活锁等理论

③ 无锁的数据结构

④ 各个语言的并发模型(如果是Java就是Java的并发模型)。

如果真的是这个职位需要深入的并发理论,认个怂也没啥。因为你不具备这个经验和基础去做这样的工作很明显不匹配,还不如回过头来静下心好好学习。


对于萌新的我来说,就是想让职场的专家提一些学习Java的意见,谢谢。

——小小小小小小小小小旺旺

答:

学习Java就一个思路,看书+多写代码。

① 学习Java基础,《Core Java》这本书很不错,《Effective Java》也是必读,这一步有什么坑的话就是,不要看《Thinking in Java》。

② 学习J2EE相关的知识。

③ 学习一些常用的开源软件。

④ 平时多看各大公司的技术公众号(比如美团点评技术团队,这里是小编强加的硬广,么么哒)。

另外个人的经验的话,在入门阶段应该以看书为主建立整体的知识体系。在提升阶段可以多看一些有质量的博客或者公众号。


读写锁和condition一般在什么场景下面使用?ConcurrentHashMap在Java 7和Java 8中差了几倍的代码量,后者看起来好复杂,能不能指点一下?

——不以物喜

答:

① 读写锁一般在读多写少的场景下使用。

② condition主要是用来做线程协调的,如果你用的Synchronized那么需要wait和notify。如果你用了ReentrantLock那么就需要condition来完成wait和notify的功能了。

③这个可以看上面第5题哈。


线程池ThreadPoolExecutor的内部机制是怎样的?

——码农一枚

答:

整体处理流程:

① 当一个任务被提交到线程池时,首先查看线程池的核心线程是否都在执行任务,否就选择一条线程执行任务,是就执行第二步。

② 查看核心线程池是否已满 , 不满就创建一条线程执行任务,否则执行第三步。

③ 查看任务队列是否已满,不满就将任务存储在任务队列中,否则执行第四步。

④ 查看线程池是否已满,不满就创建一条线程执行任务,否则就按照策略处理无法执行的任务。

在ThreadPoolExecutor中表现为:

① 如果当前运行的线程数小于corePoolSize,那么就创建线程来执行任务(执行时需要获取全局锁)。

② 如果运行的线程大于或等于corePoolSize,那么就把task加入BlockQueue。

③ 如果创建的线程数量大于了BlockQueue的最大容量, 那么创建新线程来执行该任务。

④ 如果创建线程导致当前运行的线程数超过maximumPoolSize,就根据饱和策略来拒绝该任务。

创建线程池:

① 首先要提供maxCorePoolSize,maxinumPoolSize,keepAliveTime,BlockQueue这几个线程运行所需的必要参数。

② 可选参数:饱和策略(当任务无法被执行时的处理方式)。

① ThreadPoolExecutor.AbortPolicy,用于被拒绝任务的处理程序,它将抛出RejectedExecutionException。

② ThreadPoolExecutor.CallerRunsPolicy用于被拒绝任务的处理程序,它直接在execute方法的调用线程中运行被拒绝的任务。

③ DiscardOldestPolicy用于被拒绝任务的处理程序,它放弃最旧的未处理请求,然后重试 execute。

④ DiscardPolicy用于被拒绝任务的处理程序,默认情况下它将丢弃被拒绝的任务。

提交任务:

① 无返回值的任务使用execute(Runnable)

② 有返回值的任务使用submit(Runnable)

关闭线程池:

调用shutdown或者shutdownNow,两者都不会接受新的任务,而且通过调用要停止线程的interrupt方法来中断线程,有可能线程永远不会被中断,不同之处在于shutdownNow会首先将线程池的状态设置为STOP,然后尝试停止所有线程(有可能导致部分任务没有执行完)然后返回未执行任务的列表。而shutdown则只是将线程池的状态设置为shutdown,然后中断所有没有执行任务的线程,并将剩余的任务执行完。

线程池的配置:

① 如果是CPU密集型任务,那么线程池的线程个数应该尽量少一些,一般为CPU的个数+1条线程。

② 如果是IO密集型任务,那么线程池的线程可以放的很大,如2*CPU的个数。

③ 混合型任务的话,如果可以拆分的话,可以通过拆分成CPU密集型和IO密集型两种来提高执行效率;如果不能拆分的的话就可以根据实际情况来调整线程池中线程的个数。

监控线程池的状态:

① taskCount:线程需要执行的任务个数。

② completedTaskCount:线程池在运行过程中已完成的任务数。

③ largestPoolSize:线程池曾经创建过的最大线程数量。

④ getPoolSize获取当前线程池的线程数量。

⑤ getActiveCount:获取活动的线程的数量

然后通过继承线程池,重写beforeExecute,afterExecute和terminated方法来在线程执行任务前,线程执行任务结束,和线程终结前获取线程的运行情况,根据具体情况调整线程池的线程数量。


ReentrantLock中condition的实现原理是怎么样的?和AQS的关系?

——码农一枚

答:

关于ReentrantLock中condition的实现原理网上有很多源码分析了。这里说下AQS这个东东。

在并发的世界中,有一件顶重要的事情就是执行流的协调,在Java世界中就是线程间的协调和通信,基本包括这几种:原子性管理、线程的阻塞和解除阻塞以及排队,这些功能统称同步器。

同步器的核心功能有很多,比如:内部同步状态的管理(例如:表示一个锁的状态是获取还是释放),同步状态的更新和检查操作,且至少有一个方法会导致调用线程在同步状态被获取时阻塞,以及在其他线程改变这个同步状态时解除线程的阻塞等等。

实现同步器可以有集中方法:互斥排它锁的不同形式、读写锁、信号量、屏障、Future、事件指示器以及传送队列等。每一种同步器都可以实现其他类型的同步器。但是从设计层面上讲这样做带来的复杂性、开销、不灵活等问题。所以,Java对同步器做了一个统一的抽象为构造同步器做了一个通用机制就是AQS。AQS也是J.U.C包的基石,许多功能比如锁,比如信号量等等都是基于AQS的。也就是说ReentrantLock中的condition也是基于AQS实现的。

十一


请问怎么才能有效的阅读源码?阅读过程分哪几步?

——小豆豆

一般都是带着实际问题去阅读更好,阅读源码一般的过程是:

① 熟悉文档;

② 熟悉基本流程;

③ DEBUG看源码。

十二


我在看你们之前一篇文章“Java内存访问重排序的研究”,将你们给的一个demo写了一下,但是我去掉了private volatile SomeThing object;的volatile关键字,然后测试怎么测试都不会出现new对象的时候内部重排序导致的对象创建不完整问题,这是什么原因呢?

——小林家的...

重排序是一个比较底层的操作,受好多东西影响,其中CPU是最主要的原因。我们的PC机一般都是Intel的处理器,Intel处理器有着比较复杂的重排序规则,所以Intel在很多情况下都不需要volatile关键字。你去掉这个关键字,是不是也存在着不加volatile关键字也可以的场景?

十三


项目前端用户秒杀,没有用户概念,请问后端有哪些手动防止超卖,减少后端压力。

——小小纸飞机

这个问题实在没看懂想问什么。

原文发布于微信公众号 - 美团点评技术团队(meituantech)

原文发表时间:2017-09-14

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏JAVA技术zhai

天下无难试之多线程面试刁难大全

多线程技术在互联网技术方面使用如此广泛,几乎所有的后端技术面试官都要在并发编程的使用和原理方面对小伙伴们进行各种刁难。作为一名在互联网技术行业打击过成百上千名【...

2799
来自专栏java、Spring、技术分享

java线程池

线程池能够帮助我们提高系统资源利用效率,并简化线程管理。通过并发包下的Executors(不是Executor)可以方便的创建如下几类线程池。分别为:

702
来自专栏企鹅号快讯

浅谈 Java 并发编程中的若干核心技术

作者:一字马胡 原文:http://www.jianshu.com/p/5f499f8212e7 索引 Java线程 线程模型 Java线程池 Future(各...

1756
来自专栏IT技术精选文摘

Java多线程知识小抄集(三)

51. SimpleDateFormat非线程安全 当多个线程共享一个SimpleDateFormat实例的时候,就会出现难以预料的异常。 主要原因是parse...

1796
来自专栏Java Web

Java学习笔记(4)——并发基础

前言 当我们使用计算机时,可以同时做许多事情,例如一边打游戏一边听音乐。这是因为操作系统支持并发任务,从而使得这些工作得以同时进行。 那么提出一个问题:如果我...

2633
来自专栏恰同学骚年

操作系统核心原理-4.线程原理(上):线程基础与线程同步

我们都知道,进程是运转中的程序,是为了在CPU上实现多道编程而发明的一个概念。但是进程在一个时间只能干一件事情,如果想要同时干两件或者多件事情,例如同时看两场...

1103
来自专栏程序员互动联盟

【线程池】线程池与工作队列

为什么要用线程池? 诸如 Web 服务器、数据库服务器、文件服务器或邮件服务器之类的许多服务器应用程序都面向处理来自某些远程来源的大量短小的任务。请求以某种方式...

3278
来自专栏Java学习网

Java线程使用技巧学习(二)

Java线程使用技巧学习(二)  进阶篇   3.线程本地存储   这个和前面提到的两个略有不同。ThreadLocal是在Thread类之外实现的一个功能...

17910
来自专栏精讲JAVA

11 个简单的 Java 性能调优技巧

大多数开发人员理所当然地以为性能优化很复杂,需要大量的经验和知识。好吧,不能说这是完全错误的。优化应用程序以获得最佳性能不是一件容易的事情。但是...

1868
来自专栏Java技术

【面试题】2018年最全Java面试通关秘籍汇总集!

前几天在交流群里有些小伙伴问面试相关的试题,当时给出了一些问题,苦于打字太累就没写下去了,但觉得这是一个很不负责任的表现,于是下来整理了一下近几年的私藏,特分享...

1072

扫描关注云+社区