我正在运行一个多线程应用程序,当不同的线程试图访问特定表中的相同记录时,我将面临问题。
Thread A --希望从表"LastOperations“中获得最后一条记录,因此根据ID限制1对更新顺序进行选择。--根据LastOpertaions表中的最后一条记录创建一个新记录,并将其插入其中。
线程B -想要表"LastOperations“中的最后记录,因此执行与线程A相同的活动。
两个线程都是相同的代码。只是在处理不同的数据。在这个表上,每次最大的活动线程是4-6个。
问题如果线程A用id 1000锁定最后一个记录,线程B将获取999记录并将新条目添加到表中。ID字段是一个自动增量字段,它也是主键。
假设线程1正在购买原料A和线程B正在购买原料B。两者都应该从相同的帐户中扣除最近的条目。所发生的是一个线程从帐户中取出较旧的条目,从而导致帐户余额中的错误。
对我错过了什么有什么建议吗?需要在DB端进行任何更改吗?
发布于 2017-09-16 11:23:33
我相信你正在经历的问题是事务隔离级别。线程A还没有完成创建它的记录。因此,当线程B从"LastOperations“获得最新记录为999时,999确实是表中的最后一个记录。
您可以将事务隔离级别更改为读取未提交(如果您控制了MySQL实例),但这是有风险的。如果允许脏读取,则线程A生成的完整记录可能无法在数据库中完成。(因此,“脏”读物中的“脏”。)
发布于 2017-09-20 18:18:27
不要把历史和现在混为一谈。有两张桌子:
History列出了所有的操作;它主要是INSERTed到。Current。主要是UPDATEd。当一项行动发生时:
BEGIN;
SELECT ... FROM Current ... FOR UPDATE;
INSERT INTO History ...;
UPDATE Current ...;
COMMIT;https://stackoverflow.com/questions/46253267
复制相似问题