快手二面：乐观锁是怎么用它来处理多线程问题的？

文章内容收录到个人网站，方便阅读：hardyfish.top/

内存并发（Java 层）：CAS/原子类/StampedLock

方案 A1：CAS 原子类（Atomic）

AtomicInteger stock = new AtomicInteger(100);

boolean decOnce(int n) {
    while (true) {
        int cur = stock.get();
        if (cur < n) return false;       // 不够则失败
        if (stock.compareAndSet(cur, cur - n)) { // CAS 成功表示没人改过
            return true;
        }
        // CAS 失败：有人改过，重试（可加退避）
    }
}

要点：

**比较并交换（CAS）**是硬件指令，失败重试即可。
高并发下加指数退避或限制最大重试次数，避免 CPU 自旋打满。

方案 A2：解决 ABA： AtomicStampedReference

AtomicStampedReference ref = new AtomicStampedReference(100, 0);

boolean dec(int n) {
    while (true) {
        int[] stamp = new int[1];
        int cur = ref.get(stamp);
        if (cur < n) return false;
        int newStamp = stamp[0] + 1;
        if (ref.compareAndSet(cur, cur - n, stamp[0], newStamp)) return true;
    }
}

方案 A3：读多写少下的乐观读：StampedLock

StampedLock lock = new StampedLock();
long stamp = lock.tryOptimisticRead();
int xLocal = x;           // 无锁读取
if (!lock.validate(stamp)) {         // 期间若被写，验证失败
    stamp = lock.readLock();         // 再走读锁兜底
    try { xLocal = x; } finally { lock.unlockRead(stamp); }
}

数据库并发（MySQL/Oracle 等）：版本号/条件更新

表结构

ALTER TABLE product ADD COLUMN version INT NOT NULL DEFAULT 0;

更新 SQL

-- 假设要扣减库存 1
UPDATE product
SET stock = stock - 1,
    version = version + 1
WHERE id = #{id}
  AND stock >= 1              -- 业务约束
  AND version = #{oldVersion};

Java 伪代码（MyBatis/JdbcTemplate）

Product p = dao.selectForUpdateLikeNoLock(id); // 普通查询即可（不要 FOR UPDATE）
int retry = 0, maxRetry = 5;
while (retry++ < maxRetry) {
    int rows = dao.updateStockWithVersion(id, p.getVersion());
    if (rows == 1) return true;           // 成功
    p = dao.selectById(id);               // 别人改过，拿新版本再试
}
return false;                              // 超过重试上限，交给上层处理/排队

要点：

不需要悲观锁/行锁；靠版本冲突检测避免丢失更新。
冲突时重读最新数据再尝试，或直接失败给调用方。
JPA 可用 @Version 自动完成（抛 OptimisticLockException 后应用层重试）。

分布式场景（跨进程）：Redis/WATCH 或 Lua

方案 C1：Redis WATCH/MULTI/EXEC（CAS 语义）

WATCH stock:sku1        # 监视键
val = GET stock:sku1
if val >= n:
  MULTI
  DECRBY stock:sku1 n   # 事务块
  EXEC                  # 若期间有人改过，EXEC 返回空，表示失败需重试
else:
  UNWATCH

方案 C2：Redis Lua 脚本（原子性+业务校验）

-- KEYS[1]=stockKey, ARGV[1]=n
local cur = tonumber(redis.call(\'GET\', KEYS[1]) or \'0\')
if cur >= tonumber(ARGV[1]) then
  redis.call(\'DECRBY\', KEYS[1], ARGV[1])
  return 1
else
  return 0
end