当前位置：首页 > PHP

php互斥信号实现

2026-02-16 11:45:31PHP

PHP 互斥信号实现

在 PHP 中，实现互斥信号（Mutex，互斥锁）可以通过多种方式完成，主要用于解决多进程或多线程环境下的资源竞争问题。以下是常见的实现方法：

使用文件锁（flock）

文件锁是一种简单的跨进程互斥实现方式，适用于单机多进程场景。

$fp = fopen("/tmp/lockfile", "w+");
if (flock($fp, LOCK_EX)) { // 获取独占锁
    // 临界区代码
    flock($fp, LOCK_UN); // 释放锁
} else {
    echo "无法获取锁";
}
fclose($fp);

文件路径需唯一，避免冲突。
LOCK_EX 表示独占锁，LOCK_UN 释放锁。
需处理文件打开失败和锁超时情况。

使用 Semaphore 扩展

PHP 的 sysvsem 扩展提供信号量支持，适用于更复杂的同步场景。

$semKey = ftok(__FILE__, 't');
$semId = sem_get($semKey, 1); // 第二个参数表示最大并发数

if (sem_acquire($semId)) { // 获取信号量
    // 临界区代码
    sem_release($semId); // 释放信号量
}

ftok 生成唯一键，sem_get 创建信号量。
sem_acquire 会阻塞直到获取信号量。
需确保信号量资源释放，避免死锁。

使用 Redis 分布式锁

对于分布式系统，可以通过 Redis 实现跨机器的互斥锁。

$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
$lockKey = 'resource_lock';
$token = uniqid();

// 尝试获取锁（SETNX + 过期时间）
if ($redis->set($lockKey, $token, ['NX', 'EX' => 10])) {
    try {
        // 临界区代码
    } finally {
        // 确保仅释放自己的锁（Lua 脚本避免误删）
        $script = 'if redis.call("GET", KEYS[1]) == ARGV[1] then return redis.call("DEL", KEYS[1]) else return 0 end';
        $redis->eval($script, [$lockKey, $token], 1);
    }
}

使用 SETNX 和过期时间避免死锁。
通过唯一 token 确保锁的安全性。
需处理 Redis 连接异常和锁续期问题。

使用 Pthreads 扩展（多线程）

PHP 的 pthreads 扩展支持多线程编程，提供内置的互斥锁。

php互斥信号实现

class WorkerThread extends Thread {
    private $mutex;

    public function __construct(Mutex $mutex) {
        $this->mutex = $mutex;
    }

    public function run() {
        Mutex::lock($this->mutex);
        // 临界区代码
        Mutex::unlock($this->mutex);
    }
}

$mutex = Mutex::create();
$thread = new WorkerThread($mutex);
$thread->start();
$thread->join();
Mutex::destroy($mutex);