JAVA 模拟瞬间高并发
如何模拟一个并发?当时我的回答虽然也可以算是正确的,但自己感觉缺乏实际可以操作的细节,只有一个大概的描述。
当时我的回答是:“线程全部在同一节点wait,然后在某个节点notifyAll。”
面试官:“那你听说过惊群效应吗?”
我:“我没有听过这个名词,但我知道瞬间唤醒所有的线程,会让CPU负载瞬间加大。”
面试官:“那你有什么改进的方式吗?”
我:“采用阻塞技术,在某个节点将所有的线程阻塞,在利用条件,线程的个数达到一定数量的时候,打开阻塞。”
面试官好像是比较满意,结束了这个话题。
面试结束后,我回头这个块进行了思考,要如何进行阻塞呢?我首先有一个思路就是,利用AtoInteger计算线程数,再利用synchronize方法块阻塞一个线程,根据AtoInteger的判断,执行sleep。
代码如下:
结果为:
从结果上来看,应该是可以解决问题,利用了同步锁,volatile解决了同时释放的问题,难点就在于开关。
后来查找资料,找到了一个CountDownLatch的类,专门干这个的
CountDownLatch是一个同步辅助类,犹如倒计时计数器,创建对象时通过构造方法设置初始值,调用CountDownLatch对象的await()方法则处于等待状态,调用countDown()方法就将计数器减1,当计数到达0时,则所有等待者或单个等待者开始执行。
构造方法参数指定了计数的次数
newCountDownLatch(1)
countDown方法,当前线程调用此方法,则计数减一
cdAnswer.countDown();
awaint方法,调用此方法会一直阻塞当前线程,直到计时器的值为0
cdOrder.await();
直接贴代码,转载的代码
执行结果:
上述也是一种实现方式,用countDownLatch的await()方法,代替了synchronize 和 sleep的阻塞功能,通过countDown的方法来当做开关,和计算线程数量的一种方式。
区别的话,肯定是后者会好一些,因为第一种方式依靠sleep(xxx)来阻塞把握不好最短时间,太短了,可能来没有达到固定线程数就会打开开关。
至于两者性能上的区别,目前我还不得而知,有机会测试一下。
优质内容筛选与推荐>>长按二维码向我转账
受苹果公司新规定影响,微信 iOS 版的赞赏功能被关闭,可通过二维码转账支持公众号。
已发送
发送中
微信扫一扫
关注该公众号