java - 从死锁中恢复

Question

我有一个 2 线程进程从 MySQL 表访问数据。由于使用 MySQL 是可能的，所以我有时会陷入僵局。

现在，我准备好的是:在死锁的情况下，只需将所有行更新回它们以前的状态，然后重新启动进程。

但我怀疑出现了问题，因为在一个案例中我想更新 1300 左右的数据，但在死锁之后计数显示 1700 左右。

因此，一些数据可能通过调用进程的第二个实例被处理了两次。

我应该在重新启动进程之前杀死所有正在运行的线程吗？

编辑:

我正在使用 InnoDB 并在 id 上创建索引。线程应该获取限制为 500 且带有已处理标志“N”的任何行并处理它们，然后将各个行更新为“Y”。

我还更新了一个进程 ID，以指示哪个线程应该对哪些行执行操作。

我仍然在 resultset.updaterow() 上陷入僵局

表:

create table Mail(
id integer not null auto_increment primary key,
from_eaddress varchar(50) not null,
to_address varchar(50) not null,
process_flg varchar(1) not null,
process_id varchar(50) default null,
time_stamp datetime default null,
index(id)
) engine=InnoDB;

最后这是我的工作代码: https://github.com/codezero10/MailQueue/tree/master

Answer 1

这似乎是一个交易问题。在访问信息之前，您必须在程序/ Controller 中使用必要的逻辑。如果您尝试访问正在使用的行，您总是(不是有时)会看到此错误。有时会因为两个线程无法同时访问而产生，但这是不正确的行为

注意:现代 RDBMS 自行管理其内存。因此，您需要实现一种预防算法，例如 Mutual exclusión .