AtomicInteger类中addAndGet的实现

AtomicInteger类中addAndGet的实现,第1张

AtomicInteger类中addAndGet的实现

无限循环有何帮助?

这意味着:重试直到成功。如果没有循环,则第一次可能不会成功(请参阅下文)。

在“ if(compareAndSet(current,next))”条件下可能返回false的情况是什么?

如果两个线程试图同时修改该值,则会发生这种情况。其中一个将首先到达那里。另一个将失败。

想象两个线程(A和B)试图从5递增到6

A: int current = get();  // current = 5B: int current = get();  // current = 5B: int next = current + delta;  // next = 6B: if (compareAndSet(current, next))  // OK          return next;A: int next = current + delta;  // next = 6 A: if (compareAndSet(current, next))      // fails, because "current" is still 5    // and that does not match the value which has been changed to 6 by B

请注意,此类的重点是避免锁。因此,您具有这种“乐观的货币控制”:只需假设没有其他人同时在处理数据,并且如果发现这是错误的,请回滚并重试。

在这种情况下,代码可能会陷入无限循环

并不是的。对于每一个对值有作用的线程,它只能失败一次。

在第二次迭代中从上方线程A:

A: int current = get();  => current now 6A: int next = current + delta;  => next = 7A: if (compareAndSet(current, next))  => now OK

可以想象,如果其他线程不断地更新该值,那么一个线程将永远等待,直到那时。为了避免这种情况,您需要对“公平”进行一些定义(并发包中的其他一些工具也支持)。



欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/zaji/5498658.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-12-12
下一篇 2022-12-12

发表评论

登录后才能评论

评论列表(0条)

保存