jodis原子性问题

[lvdelu]

for (;;) {
int current = nextIdx.get();
int next = current >= pools.size() - 1 ? 0 : current + 1;
if (nextIdx.compareAndSet(current, next)) {
return pools.get(next).pool.getResource();
}
}

这段源码存在原子性问题

[Apache9]

啥问题？

[lvdelu]

@OverRide
public Jedis getResource() {
ImmutableList pools = this.pools;
if (pools.isEmpty()) {
throw new JedisException("Proxy list empty");
}

        for (;;) {
            int current = nextIdx.get();
            int next = current >= pools.size() - 1 ? 0 : current + 1;
            if (nextIdx.compareAndSet(current, next)) {
                return pools.get(next).pool.getResource();
            }
        }
    
}

这段代码存在原子性问题

[lvdelu]

应该改成下面这样
@OverRide
public Jedis getResource() {
ImmutableList pools = this.pools;
if (pools.isEmpty()) {
throw new JedisException("Proxy list empty");
}
synchronized (this.pools) {
for (;;) {
int current = nextIdx.get();
int next = current >= pools.size() - 1 ? 0 : current + 1;
if (nextIdx.compareAndSet(current, next)) {
return pools.get(next).pool.getResource();
}
}
}
}

[Apache9]

你是实际遇到问题了？还是看代码看到这里觉得有问题？
那个pools是个ImmutableList，生成了就不会变了，每次更新列表的时候都是创建一个新的ImmutableList，不会改之前的。

[lvdelu]

看代码啊，pools是原子的，for 中的死循环不是原子操作啊

[Apache9]

那个nextIdx是AtomicInteger啊，标准的CAS原子操作

[lvdelu]

current不是原子的啊

[Apache9]

current是个局部变量啊，只有本线程能访问到。。。

[lvdelu]

我错了，囧