php 线程 互斥锁

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了php 线程 互斥锁，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1367字，纯文字阅读大概需要2分钟。

内容图文

在进行并发操作时,会导致共享数据的完整性的问题,要加入锁,在任意时刻只有一个线程访问该对象
在PHP中定义专门用于线程同步控制的mutex的函数, pthreads v3 中已经将 Mutex 类移除。
简单的计数器程序，有加锁和没有加锁的情况,pthreads v3使用synchronized同步处理

<?php
class CounterThread extends Thread {
    public $counter = 0;
    public $handle;
    public $mutex;
    public function __construct($handle,$mutex = null){
        $this->mutex = $mutex;
    }
    public function run() {
        //加锁
        if($this->mutex){
            $locked=Mutex::lock($this->mutex);
        }
        $this->handle = fopen("/tmp/counter.txt", "w+");
        $this->counter = intval(fgets($this->handle));
        $this->counter++;
        rewind($this->handle);
        fwrite($this->handle, $this->counter."\r\n");
        printf("Thread #%lu says: %s\n", $this->getThreadId(),$this->counter);
        $this->close();
        if($this->mutex){
            //释放锁
            Mutex::unlock($this->mutex);
        }
    }
    public function close()
    {
        print_r(fclose( $this->handle));echo PHP_EOL;
    }
}
$handle=fopen("/tmp/counter.txt", "w+");
//没有互斥锁
for ($i=0;$i<10;$i++){
    $threads[$i] = new CounterThread($handle);
    $threads[$i]->start();
    sleep(1);
}

//创建一个互斥锁 
//参数设置true，表示创建互斥量之后，立即加锁，
$mutex = Mutex::create();
for ($i=0;$i<10;$i++){
    $threads[$i] = new CounterThread($handle,$mutex);
    $threads[$i]->start();
    sleep(1);
}
//销毁互斥量
Mutex::destroy($mutex);

/*
Mutex::unlock($mutex);
for ($i=0;$i<50;$i++){
    $threads[$i]->join();
}
Mutex::destroy($mutex);
*/

?>

内容总结

以上是互联网集市为您收集整理的php 线程 互斥锁全部内容，希望文章能够帮你解决php 线程 互斥锁所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端