0

假设我有一张名为tasks. 每个任务都有一个status. 我采取其中一项处于状态的任务To Manage，将其置于In Management状态，然后运行为其创建任务的过程（可能需要几秒钟才能完成）。

在执行结束时，任务可能会返回To Manage或Completed状态，这取决于程序是否必须再次运行。

现在假设有多个进程同时运行此活动，以便一起完成或以其他方式处理多个不同的任务。

我想确保两个进程不会同时管理同一个任务。为此，上述活动应在事务中执行：

$db->beginTransaction(); /* transaction A */

/* Reads one task from the database (SELECT query with LIMIT 1) which is in the `To Manage` status and returns it */
$task = $tasks->getNextTask(); /* operation 1 */

/* Changes the status into the `In Management` status (UPDATE query) */
$task->changeStatusToManage(); /* operation 2 */

$db->commit();

$task->execute(); /* operation 3 */

我正在使用 MySql 数据库，表是 InnoDB，具有 READ COMMITTED 隔离级别：https ://dev.mysql.com/doc/refman/5.7/en/innodb-transaction-isolation-levels.html

我们说To Manage状态中只有一项任务。如果两个进程（P1 和 P2）同时执行并且transaction A不存在，则可能会发生以下情况：

Instant 1: (operation 1) P1 reads the task id 100 in `To Manage` status
Instant 2: (operation 1) P2 reads the task id 100 in `To Manage` status
Instant 3: (operation 2) P1 puts the task id 100 in the `In Management` status
Instant 4: (operation 2) P2 puts the task id 100 in the `In Management` status
Instant 5: (operation 3) P1 performs the task id 100
Instant 6: (operation 3) P2 performs the task id 100

但是，操作 1-2-3 实际上是在事务中执行的，这种情况应该是不可能的。

  • 你能确认事实确实如此吗？
  • 我是否需要在执行LOCK操作 1 之前执行显式读取任务表并在操作 2 完成后释放它？
  • 我还应该做些什么来防止意外结果？

DB结构比上面描述的要复杂得多。当我更改任务状态时，我也会在另一个表上写入日志。这是由代码（模型类）本身完成的。我有任务表，task_status 表，任务上有一个外键，还有一个 task_status_change（即日志表）。每个 txn 执行 1 次读取（获取任务），2 次写入（更改状态和写入日志）。所以我需要执行与此类似的操作（伪代码）：

BEGIN;
$id = SELECT task_id FROM task WHERE task_status_id = 1 LIMIT 1;
UPDATE task SET task_status_id = 2 WHERE task_id = $id;
INSERT INTO task_status_change SET task_id = $id, task_status_id = 2;
COMMIT;

正如我上面提到的，我使用的是 READ COMMITED 隔离级别。我试图同时启动两个进程，在同一个任务池上一起运行。

第一个进程选择的任务 ID（ID 和时间戳）：

55 1496925510
274 1496925512
384 1496925512
589 1496925513
648 1496925513
1088 1496925513
1990 1496925513

第二个进程选择的任务 ID（ID 和时间戳）：

55 1496925510
274 1496925512
589 1496925512
648 1496925513
810 1496925513
1088 1496925513
2049 1496925514

谢谢

4

1 回答 1

1

getNextTask应该修改status并获取它在单个事务中修改的任务的 ID。一种方式（在伪代码中）：

BEGIN;
$id = SELECT id ... 
        WHERE status = 'idle'
        LIMIT 1 ... FOR UPDATE;
UPDATE ...  SET status = 'management' WHERE id = $id
COMMIT;

根据您的表结构，可以在单个原子UPDATE语句中执行事务。（你没有提供太多细节。）

为每个状态转换做类似的事情。

这为长时间运行的代码集合提供了事务语义，只使用status数据库中的一个。

这听起来像是一种“排队”机制。我有一个口头禅：“不要排队，就去做。” 这意味着每当您有任务要做时，生成工作进程可能会更容易/更快/更简单，而不是排队等。

于 2017-06-08T05:30:14.810 回答