为什么一个线程无法检测到另一个线程更新的更改值？ [复制]

Question

我正在使用 SQLAlchemy、python 和多线程编写程序。

在我的设计中，线程 A 使用了一个 while True 循环。在每个循环中，它通过 SQLAlchemy 从数据库中获取查询的对象，然后检查对象的一个​​字段。如果满足条件，则中断while循环。数据库中记录的字段将由线程B更新。

我的线程-A 代码：

    engine = create_engine('postgresql://postgres:passw0rd@localhost:5432/mini_amazon')
    Session = sessionmaker(bind=engine, expire_on_commit=False)

    @contextmanager
    def session_scope():
        """
        Provide a transactional scope around a series of operations.
        """
        session = Session()
        try:
            yield session
            session.commit()
        except:
            session.rollback()
            raise
        finally:
            session.close()

    with session_scope() as session:
        while True:
            print('Waiting')
            order = session.query(models.Order).get(arrived_message.packageid)
            time.sleep(1)
            if order.status == 'packed':
                break

        order.status = 'loading'

结果发现数据库中的记录已经被线程B更新为线程A中while循环的break-condition值。但是，Thread-A 一直在 while 循环中等待并且没有中断。

有人可以提供一些见解吗？

谢谢！

Answer 1

这是由交易的孤立性质造成的

具有平均隔离度的事务将保持它迄今已加载的状态，并继续为您提供事务本地相同的状态，即使实际数据已更改 - 这在事务隔离中称为可重复读取用语。

How to disable SQLAlchemy caching?