原子循环计数器

简介:

感谢同事[孙棋]的投稿

现实当中很多场景,需要进行轮训服务,比如轮训在10个日志文件当中写日志,在10台机器上轮训的去调用以实现负载均衡,常规的做法,如tomcat的Poller线程轮训选择,就采用


1 Math.abs(pollerRotater.incrementAndGet()) % pollers.length

此地需要取原子自增的绝对值模以poller线程数,那是否有更好的实现呢?


01 public class CycleAtomicInteger {
02 private final static long PARK_TIME = 1000L * 1000;
03  
04 private AtomicInteger counter = new AtomicInteger(0);
05  
06 private int range;
07  
08 public CycleAtomicInteger(int range) {
09     if (range < 2)
10         throw new IllegalArgumentException();
11     this.range = range;
12 }
13  
14 /**
15  * 获取下个原子值
16  *
17  * @return
18  */
19 public int next() {
20     for (;;) {
21         int c = counter.get();
22         int next = (c + 1) % range;
23         if (counter.compareAndSet(c, next)) {
24             return c;
25         } else {
26             LockSupport.parkNanos(PARK_TIME);
27         }
28     }
29 }
30  
31 }

这样就可以快速的实现rr的效果,同时也避免了abs的过程,至于LockSupport.parkNanos(PARK_TIME);加了这个后,4个线程执行2亿次的计算,我本机从原来的16s减少到4s,至于为什么要加这个,可参见更快的AtomicInteger

当然,这样设计会存在cas的aba问题,但对当前的case需求,其实是满足的,也不存在问题

目录
相关文章
|
2月前
|
存储 API 调度
序列计数器和顺序锁 【ChatGPT】
序列计数器和顺序锁 【ChatGPT】
|
3月前
|
缓存 Java 编译器
|
6月前
计数器:使用类
计数器:使用类
33 0
|
6月前
|
算法 前端开发
2665. 计数器 II
2665. 计数器 II
30 0
|
6月前
|
机器学习/深度学习 算法 前端开发
2620. 计数器
2620. 计数器
36 0
|
Java
线程计数器的使用
线程计数器的使用
49 1
三个线程循环顺序打印
三个线程循环顺序打印
79 0
|
缓存 安全 Java
《JUC并发编程 - 高级篇》05 -共享模型之无锁 (CAS | 原子整数 | 原子引用 | 原子数组 | 字段更新器 | 原子累加器 | Unsafe类 )
《JUC并发编程 - 高级篇》05 -共享模型之无锁 (CAS | 原子整数 | 原子引用 | 原子数组 | 字段更新器 | 原子累加器 | Unsafe类 )
《JUC并发编程 - 高级篇》05 -共享模型之无锁 (CAS | 原子整数 | 原子引用 | 原子数组 | 字段更新器 | 原子累加器 | Unsafe类 )
|
存储 缓存 安全
《JUC并发编程 - 高级篇》05 -共享模型之无锁 (CAS | 原子整数 | 原子引用 | 原子数组 | 字段更新器 | 原子累加器 | Unsafe类 )(三)
《JUC并发编程 - 高级篇》05 -共享模型之无锁 (CAS | 原子整数 | 原子引用 | 原子数组 | 字段更新器 | 原子累加器 | Unsafe类 )
《JUC并发编程 - 高级篇》05 -共享模型之无锁 (CAS | 原子整数 | 原子引用 | 原子数组 | 字段更新器 | 原子累加器 | Unsafe类 )(三)
《JUC并发编程 - 高级篇》05 -共享模型之无锁 (CAS | 原子整数 | 原子引用 | 原子数组 | 字段更新器 | 原子累加器 | Unsafe类 )(二)
《JUC并发编程 - 高级篇》05 -共享模型之无锁 (CAS | 原子整数 | 原子引用 | 原子数组 | 字段更新器 | 原子累加器 | Unsafe类 )
《JUC并发编程 - 高级篇》05 -共享模型之无锁 (CAS | 原子整数 | 原子引用 | 原子数组 | 字段更新器 | 原子累加器 | Unsafe类 )(二)