Параллельный SELECT...FOR UPDATE, вызывающий высокую загрузку процессора mariaDB

Я пытаюсь протестировать различные способы перемещения данных 1M из одной таблицы в другую, не блокируя целые таблицы, а затем отмечая строки как обработанные.
У меня есть два скрипта: один использует простой выбор вставки (limitedLock.php), а другой можно запускать параллельно (parallel.php)
Оба скрипта используют одни и те же настройки базы данных
Я запускаю каждый скрипт в режиме CLI с помощью следующих команд:

date && limitedLock.php && date
date & php parallel.php & php parallel.php & php parallel.php & wait && date

Удивительно, но оба скрипта работают так же быстро (18 секунд каждый на моем компьютере), но при запуске параллельного.php mariadb использует весь процессор (верхняя команда показывает использование 300% !!!). Я не понимаю, почему Parallel.php использует так много процессора и что я могу сделать, чтобы предотвратить это?

вот код для воспроизведения проблемы:

<?php
//fixture.php
$createFrom = <<<SQL
CREATE TABLE IF NOT EXISTS from_table(
    id INT NOT NULL AUTO_INCREMENT,
    `state` VARCHAR(10),
    PRIMARY KEY(id),
    KEY state_idx (state)
)
SQL;

$createTo = <<<SQL
CREATE TABLE IF NOT EXISTS to_table(
    id INT,
    PRIMARY KEY(id)
)
SQL;


$conn = new PDO('mysql:host=mariadb;dbname=some_db', 'root', 'root');

$conn->exec('DROP TABLE IF EXISTS from_table');
$conn->exec('DROP TABLE IF EXISTS to_table');
$conn->exec($createFrom);
$conn->exec($createTo);
$values = str_repeat("('to_process'),", 1_000_123);
$insert = 'INSERT INTO from_table (`state`) VALUES ' . rtrim($values, ',');
$conn->exec($insert);

ограниченныйLock.php:

<?php

$conn = new PDO('mysql:host=mariadb;dbname=some_db', 'root', 'root');
$lastId = 0;
$limit = 1000;

do {
    $select = <<<SQL
SELECT id
FROM from_table
WHERE id > {$lastId}
AND state = 'to_process'
ORDER BY id
LIMIT {$limit}
SQL;
    $stmt = $conn->query($select);
    $result = $stmt->fetchAll();
    $ids = array_column($result, 'id');
    $lastId = end($ids);
    $inClause = implode(',', $ids);

    $insert = <<<SQL
INSERT INTO to_table(id)
SELECT id
FROM from_table
WHERE id IN ({$inClause})
SQL;

    $update = <<<SQL
UPDATE from_table
SET state = 'processed'
WHERE id IN ({$inClause})
SQL;

    $conn->beginTransaction();
    $conn->exec($insert);
    $conn->exec($update);
    $conn->commit();
} while (count($ids) === $limit);

параллельный.php

<?php

$lockRows = <<<SQL
CREATE TEMPORARY TABLE ids_to_process
SELECT id
FROM from_table
WHERE state = 'to_process'
ORDER BY id
LIMIT 1000
FOR UPDATE SKIP LOCKED
SQL;

$insert = <<<SQL
INSERT INTO to_table(id)
SELECT ft.id
FROM from_table ft
JOIN ids_to_process itp ON itp.id = ft.id
SQL;

$update = <<<SQL
UPDATE from_table ft
JOIN ids_to_process itp ON itp.id = ft.id 
SET state = 'processed'
SQL;

$conn = new PDO('mysql:host=mariadb;dbname=some_db', 'root', 'root');
$stmt = $conn->query('SELECT id FROM from_table order by id desc limit 1');
$lastId = (int) $stmt->fetch()['id'];

do {
    $conn->exec('SET TRANSACTION ISOLATION LEVEL READ COMMITTED');
    try {
        $conn->beginTransaction();
        $conn->exec($lockRows);
        $conn->exec($insert);
        $conn->exec($update);
        $conn->exec('DROP TEMPORARY TABLE IF EXISTS ids_to_process');
        $conn->commit();
        //echo getmypid() . " - commited\n";
    } catch (Exception $e) {
        $conn->rollBack();
        exit(getmypid() . PHP_EOL . $e->getMessage());
    }

    //if last id is in to_table then all rows have been transfered and the loop must stop
    $stmt = $conn->query("SELECT id FROM to_table WHERE id = {$lastId} limit 1");
    $result = $stmt->fetch();
} while (empty($result));