MySql 查询延迟时间/死锁？

Question

当有多个 PHP 脚本并行运行时，每个脚本都重复对同一个表中的同一条记录进行 UPDATE 查询，在每次查询更新表之前是否可能存在“滞后时间”？

我基本上有 5-6 个并行运行的 PHP 脚本实例，都是通过 cron 启动的。每个脚本都会获取 items 表中的所有记录，然后循环遍历并处理它们。

但是，为了避免多次处理同一项目，我将最后一个正在处理的项目的 ID 存储在单独的表中。这就是我的代码的工作原理：

function getCurrentItem()
{
  $sql = "SELECT currentItemId from settings";
  $result = $this->db->query($sql);
  return $result->get('currentItemId');
}

function setCurrentItem($id)
{
   $sql = "UPDATE settings SET currentItemId='$id'";
   $this->db->query($sql);
}

$currentItem = $this->getCurrentItem();

$sql = "SELECT * FROM items WHERE status='pending' AND id > $currentItem'";
$result = $this->db->query($sql);
$items = $result->getAll();

foreach ($items as $i)
{
   //Check if $i has been processed by a different instance of the script, and if so, 
   //leave it untouched.
   if ($this->getCurrentItem() > $i->id) 
     continue;

   $this->setCurrentItem($i->id);
   // Process the item here
}

但是尽管采取了所有预防措施，大多数项目都会被多次处理。这让我认为 PHP 脚本运行的更新查询与数据库实际更新记录之间存在一些滞后时间。

这是真的吗？如果是这样，我应该使用什么其他机制来确保 PHP 脚本始终只获取最新的 currentItemId 即使有多个脚本并行运行？使用文本文件而不是数据库会有帮助吗？

Answer 1

如果并行运行，则几乎没有措施可以避免竞争条件。

script1:

getCurrentItem() yields Id 1234
...context switch to script2, before script 1 gets to run its update statement.

script2: 
getCurrentItem() yields Id 1234

两个脚本都处理 Id 1234

你想要更新并检查项目的状态，这是一个全有或全无的操作，你不需要设置表，但你会做这样的事情（伪代码）：

SELECT * FROM items WHERE status='pending' AND id > $currentItem

foreach($items as $i) {
 rows =  update items set status='processing' where id = $i->id and status='pending';
  if(rows == 0) //someone beat us to it and is already processing the item
    continue;
   process item..
 update items set status='done' where id = $i->id;
}

Answer 2

您需要的是任何线程都能够：

• 找到
• 该项目正在处理的待处理项目记录（在 settings 表中）

并且它需要一次性完成这两件事，中途没有任何其他线程干扰。

我建议将整个 SQL 放在存储过程中；这将能够将整个事情作为单个事务来运行，这使得它免受竞争线程的影响。