确认Django竞态条件可能性及寻求修复方案

开发者阿泽

2026-5-29

1. 确认竞态条件是否存在

是的，这种竞态条件完全有可能发生，尤其是在以下场景中：

场景一：数据库事务提交延迟 + 信号执行时机问题

如果你的MyRequestLog.save()操作是在一个数据库事务中执行的，Django的post_save信号默认会在事务提交之前触发。此时：

虽然信号处理函数中的instance对象在内存中已经是stepCode=100的状态，但数据库里的这条记录还没被持久化（事务未提交）。
如果此时有其他并发操作（比如前端轮询触发的后端逻辑）依赖数据库状态，或者在事务提交前有其他进程修改了该实例，就可能导致信号里的判断逻辑与实际数据库状态不一致，最终跳过nextStep的启动。

场景二：并发修改同一实例

如果多个后端进程/线程同时操作同一个MyRequestLog实例：

当你将实例的stepCode设为100并保存后，在post_save信号执行之前，另一个进程可能已经修改了该实例的stepCode。
若信号处理中需要从数据库重新读取实例状态（比如隐式的查询操作），就会获取到被修改后的stepCode，导致判断条件不成立。

从你的描述来看，更可能是第一种场景导致的问题：事务未提交时信号已触发，后续逻辑因数据未持久化出现状态不一致。

2. 修复方案

针对上述问题，这里提供几种可行的修复方案，按优先级排序：

方案一：使用`transaction.on_commit`延迟信号处理

将信号处理逻辑包裹在transaction.on_commit中，确保只有当事务提交成功、数据完全持久化到数据库后，才执行启动nextStep的逻辑：

from django.db import transaction
from django.db.models.signals import post_save
from django.dispatch import receiver

@receiver(post_save, sender=MyRequestLog)
def steptwo_launcher(sender, instance, **kwargs):
    GeneralLogging(calledBy='MyRequestLog', logmsg='enter steptwo_launcher').save()
    
    def execute_next_step():
        # 重新读取实例，确保获取数据库中最新状态
        fresh_instance = MyRequestLog.objects.get(pk=instance.pk)
        if fresh_instance.stepCode == 100:
            GeneralLogging(calledBy='MyRequestLog', logmsg='step code 100 found. launch next step').save()
            nextStep.delay(fresh_instance.requestId, False)
    
    # 事务提交后才执行后续逻辑
    transaction.on_commit(execute_next_step)

这样做的好处是：

彻底避免事务未提交导致的状态不一致问题；
通过重新读取实例，规避内存对象与数据库状态不同步的风险。

方案二：使用数据库行级锁防止并发修改

如果问题源于并发修改同一MyRequestLog实例，可以在保存和信号处理过程中使用行级锁，确保同一时间只有一个进程能修改该实例：

# 在保存MyRequestLog的代码中加锁
from django.db import transaction

with transaction.atomic():
    # 加行级锁，阻止其他进程修改该实例
    my_log = MyRequestLog.objects.select_for_update().get(pk=log_id)
    my_log.stepCode = 100
    my_log.save()

# 信号处理函数中也可按需加锁
@receiver(post_save, sender=MyRequestLog)
def steptwo_launcher(sender, instance, **kwargs):
    GeneralLogging(calledBy='MyRequestLog', logmsg='enter steptwo_launcher').save()
    
    with transaction.atomic():
        fresh_instance = MyRequestLog.objects.select_for_update().get(pk=instance.pk)
        if fresh_instance.stepCode == 100:
            GeneralLogging(calledBy='MyRequestLog', logmsg='step code 100 found. launch next step').save()
            nextStep.delay(fresh_instance.requestId, False)

行级锁会阻止其他进程在当前事务完成前修改该实例，彻底避免并发导致的状态覆盖。

方案三：替换信号为显式调用

如果信号的异步执行时机带来了不确定性，可以去掉post_save信号，改为在保存MyRequestLog的代码中显式调用启动逻辑：

# 保存MyRequestLog的代码块
my_log = MyRequestLog.objects.create(stepCode=100, requestId=request_id, ...)
# 直接执行下一步逻辑
if my_log.stepCode == 100:
    GeneralLogging(calledBy='MyRequestLog', logmsg='step code 100 found. launch next step').save()
    nextStep.delay(my_log.requestId, False)

这种方式逻辑更直接，完全规避了信号异步执行的问题，也更容易调试和维护。

内容的提问来源于stack exchange，提问作者John Diller