PHP 互斥锁：如何确保代码的线程安全？

// 假设库存为 10$stock = 10;
// 多个请求同时到达，每个请求都扣减库存for ($i = 0; $i < 20; $i++) {    $stock--;}// 最终库存可能不是我们预期的 0，而是负数

composer require pudongping/wise-locksmith

<?phprequire 'vendor/autoload.php';use Pudongping\WiseLocksmith\Locker;
$path = tempnam(sys_get_temp_dir(), 'wise-locksmith-flock-');$fileHandler = fopen($path, 'r+');$locker = new Locker();try {    $locker->flock($fileHandler, function () use ($stock) {        // 这里写你想保护的代码        $stock--;        // 确保操作的原子性    });} catch (\Exception $e) {    // 处理异常}fclose($fileHandler);unlink($path);

<?php$redis = new \Redis();$redis->connect('127.0.0.1', 6379);$locker = new Locker();try {    $locker->redisLock($redis, 'redisLock', function () use ($stock) {        // 这里写你想保护的代码        $stock--;        // 确保操作的原子性    });} catch (\Exception $e) {    // 处理异常}

<?php$redisInstances = [    ['host' => '127.0.0.1', 'port' => 6379],    // 其他 Redis 实例...];$redis = array_map(function ($v) {    $redis = new \Redis();    $redis->connect($v['host'], $v['port']);    return $redis;}, $redisInstances);$locker = new Locker();try {    $locker->redLock($redis, 'redLock', function () use ($stock) {        // 这里写你想保护的代码        $stock--;        // 确保操作的原子性    });} catch (\Exception $e) {    // 处理异常}

<?php$locker = new Locker();try {    $locker->channelLock('channelLock', function () use ($stock) {        // 这里写你想保护的代码        $stock--;        // 确保操作的原子性    });} catch (\Exception $e) {    // 处理异常}

<?php// 假设我们有一个全局的 Redis 连接实例$redis = new \Redis();$redis->connect('127.0.0.1', 6379);
// 库存扣减操作function decreaseStock($productId, $quantity) {    $locker = new Locker();    try {        $locker->redisLock($redis, "stock_lock_{$productId}", function () use ($productId, $quantity) {            // 这里写你想保护的代码            // 假设我们从数据库中获取当前库存            $stock = getStockFromDatabase($productId);            if ($stock >= $quantity) {                // 更新库存                updateStockInDatabase($productId, $stock - $quantity);            }        });    } catch (\Exception $e) {        // 处理异常    }}
// 调用扣减库存函数decreaseStock(123, 1);