租约接管与过期执行者的写入隔离

实现与取舍

代码示例

SQLite 演示过期代次无法完成任务

Python 标准库可运行，只演示受条件约束的本地提交；逻辑时间由测试注入，生产使用统一时间源并实现续约。

import sqlite3
c = sqlite3.connect(':memory:')
c.execute('CREATE TABLE jobs(id TEXT PRIMARY KEY, owner TEXT, until INTEGER, fence INTEGER, state TEXT)')
c.execute("INSERT INTO jobs VALUES ('r', '', 0, 0, 'ready')")
def claim(owner, now):
    with c:
        cur = c.execute("UPDATE jobs SET owner=?, until=?, fence=fence+1, state='running' WHERE id='r' AND until<=? AND state IN ('ready','running')", (owner, now+5, now))
        if cur.rowcount != 1: return None
        return c.execute("SELECT fence FROM jobs WHERE id='r'").fetchone()[0]
def finish(owner, token, now):
    with c:
        return c.execute("UPDATE jobs SET state='done' WHERE id='r' AND owner=? AND fence=? AND until>? AND state='running'", (owner, token, now)).rowcount
a = claim('A', 0)
b = claim('B', 6)
print(a, b)
print('old:', finish('A', a, 7))
print('new:', finish('B', b, 7))

预期输出

1 2
old: 0
new: 1

工程推演

场景

假设工程场景：长文研究任务被两个 Worker 接管。

设计决策

领取代次递增，文章草稿提交同时验证代次和有效租约；远端操作单独用幂等键。

验证目标

验收目标是旧 Worker 无法覆盖新 Worker 的草稿，且接管状态可追踪。

适用边界

外部资源不检查 token 时，本地 fencing 无法禁止旧请求在远端执行。

易错点

• 认为 TTL 过期会杀死旧 Worker
• token 随机生成而不是单调递增
• 只在 Worker 本地检查 token
• 把整个长任务放在数据库锁事务里

参考资料

依据公开技术资料设计；参考资料支持技术机制，场景与评分标准为本站设计，不代表某公司面试原题。 新增问答与迁移案例用于原理讲解，来源核查与案例运行验证分别记录。

• Redis：Distributed locks 与 fencing 注意事项
• PostgreSQL SELECT：FOR UPDATE 与 SKIP LOCKED
• PostgreSQL：SELECT 锁定与 SKIP LOCKED

检查自己理解到哪一步

读完后可以对照这些标准解释原理、边界和取舍。掌握程度由你自评；需要进一步验证时，再完成下方小任务。

基础达标

知道租约过期不代表旧 Worker 已停止。

中高级信号

用递增令牌和条件更新拒绝陈旧写入。

资深信号

说明各个资源是否支持令牌，以及不支持外部系统的补充控制。