如何解决并发执行中的锁定问题？使用malkusch/lock库可以！-composer-PHP中文网

如何解决并发执行中的锁定问题？使用malkusch/lock库可以！

王林

发布： 2025-03-27 09:44:12

原创

754人浏览过

可以通过以下地址学习 Composer：学习地址

在开发需要处理并发执行的应用程序时，确保关键代码段的互斥访问是至关重要的。最近，我在开发一个需要处理多个用户同时访问银行账户余额的系统时，遇到了一个棘手的问题：多个用户同时尝试更新账户余额，导致数据不一致。我尝试了多种方法来解决这个问题，但效果不佳。直到我发现了 malkusch/lock 库，才真正解决了我的困扰。

malkusch/lock 是一个用于 PHP 的互斥锁库，通过 Composer 可以轻松安装：

composer require malkusch/lock

登录后复制

这个库提供了几种锁的实现方式，包括 FlockMutex、MemcachedMutex、RedisMutex、SemaphoreMutex、MySQLMutex、PostgreSQLMutex 和 DistributedMutex。这些实现可以根据你的需求选择，确保在并发环境中，关键代码段只能被一个进程或线程执行。

以下是一个使用 RedisMutex 的简单示例，展示如何确保银行账户余额的更新操作互斥执行：

use Malkusch\Lock\Mutex\RedisMutex;

$redis = new \Redis();
$redis->connect('localhost');
$mutex = new RedisMutex($redis, 'balance');

$newBalance = $mutex->synchronized(static function () use ($bankAccount, $amount) {
    $balance = $bankAccount->getBalance();
    $balance -= $amount;
    if ($balance < 0) {
        throw new \DomainException('You have no credit');
    }
    $bankAccount->setBalance($balance);

    return $balance;
});

登录后复制

在这个例子中，$mutex->synchronized() 方法确保了代码块在任何时刻只能被一个进程执行，避免了多个用户同时更新余额导致的数据不一致问题。

此外，malkusch/lock 库还支持双重检查锁定模式，通过 check() 和 then() 方法，可以在锁定之前先进行条件检查，进一步优化性能和资源使用：

use Malkusch\Lock\Mutex\RedisMutex;
use Malkusch\Lock\Util\DoubleCheckedLocking;

$redis = new \Redis();
$redis->connect('localhost');
$mutex = new RedisMutex($redis, 'balance');

$newBalance = $mutex->check(static function () use ($bankAccount, $amount): bool {
    return $bankAccount->getBalance() >= $amount;
})->then(static function () use ($bankAccount, $amount) {
    $balance = $bankAccount->getBalance();
    $balance -= $amount;
    $bankAccount->setBalance($balance);

    return $balance;
});

登录后复制

在这个例子中，只有当账户余额足够时，才会尝试获取锁并执行更新操作，避免了不必要的锁等待。

使用 malkusch/lock 库不仅解决了我的并发问题，还大大简化了代码，提高了系统的可靠性和性能。如果你也面临类似的并发执行问题，强烈推荐尝试这个库。

以上就是如何解决并发执行中的锁定问题？使用malkusch/lock库可以！的详细内容，更多请关注php中文网其它相关文章！