AtomicBoolean
主要用来解决并发编程中的线程安全题目,防止某段代码重复执行或确保某项任务只能执行一次。代码中常用来作为一个标志变量,以控制并发流程。AtomicBoolean体现的是一种无锁机制,依靠底层的高效的CAS原子操纵实现,提供高效的线程安全操纵。
CAS简介
CAS的核心思想是'比较和交换'
如果内存中的值与预期值相称,则将其更新为新值,否则什么都不操纵。
三个操纵数:内存值(V,被操纵的变量存在内存中)预期值(E,操纵前线程认为的值应该是此值)更新值(U,如果内存值与预期值相称则更新为此值)
比较V&E--> 如果V== E 把V的值更新为U,并返回true;--> 如果V!=E 则不更新V值,并返回false
底层是依赖CPU的硬件指令来实现。体现的是一种无锁机制,不须要通过显式的加锁解锁来控制线程的执行,避免了线程上下文切换带来的开销。
CAS的一些缺点 如ABA题目 可自行查阅。
AtomicBoolean中的几个常用API
- get():获取当前值
- set(boolean newValue):设置新值(非原子性)
- compareAndSet(boolean expect, boolean update):如果当前值(V)等于预期值(E)则将其更新为更新值(U)并返回true
- getAndSet(boolean newValue):原子性设置新值并返回旧值
AtomicBoolean中的CAS
核心方法:compareAndSet(boolean expect, boolean update)
ReentrantLock
ReentrantLock是一种基于AQS框架实现的应用,是JDK中实现并发编程的本事,它的功能类似synchronized是一种互斥锁,可以保证线程安全。
- 可重入:同一个线程可以多次获取同一个锁而不会导致死锁
- 公平性:可以根据线程请求锁的顺序分配(公平锁)
- 性能上:ReentrantLock更适合复杂的并发场景
ReentrantLock锁会导致整体的吞吐量下降,队列中除了第一个线程 其他的线程都会阻塞(大概会导致其他线程饿死),cpu唤醒其他线程也会带来开销。
注意事项:
- 确保加锁与解锁配对(解锁放在finally中确保发生异常,也能正常解锁,避免锁一直被占用)
- 避免出现死锁:多个线程尝试获取多把锁时避免出现死锁题目
- 锁的顺序要一致:确保不同线程获取锁的顺序雷同
- 尝试获取锁(tryLock)时 要设置等待时间,避免长时间等待
- 不要长时间占有锁(将锁的作用返回设置到最小化,减少临界区的代码量)
- 精确处理停止
- ReentrantLock支持可停止锁,如果线程在等待锁时被停止,会抛出 InterruptedException要可以或许精确处理
将以上两种方法混合利用(实际上应该是多余的)整体代码布局如下- private ReentrantLock createXXXLock = new ReentrantLock();
- private AtomicBoolean createXXXFlag = new AtomicBoolean(false);
- if (createXXXFlag.get()) {
- log.info("XXX");
- return;
- }
- createXXXLock.lock();
- try {
- if (createXXXFlag.compareAndSet(false, true)) {
- try {
- // 业务逻辑处理
- throw new RuntimeException("模拟异常");
- } catch (Exception e) {
- log.error("xxx", e.getMessage());
- } finally {
- // 无论逻辑是否成功,确保标志位被重置
- createXXXFlag.set(false);
- }
- } else {
- log.info("xxxx");
- }
- } finally {
- // 确保锁的释放
- createXXXLock.unlock();
- }
复制代码 代码中看到有同事这样利用,故学习一下~~~ 不喜勿喷
免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!更多信息从访问主页:qidao123.com:ToB企服之家,中国第一个企服评测及商务社交产业平台。 |