zoukankan      html  css  js  c++  java
  • PHP进程通信基础——信号量+共享内存通信

    PHP进程通信基础——信号量+共享内存通信

    PHP进程通信基础——信号量+共享内存通信

    由于进程之间谁先执行并不确定,这取决于内核的进程调度算法,其中比较复杂。由此有可能多进程在相同的时间内同时访问共享内存,从而造成不可预料的错误。信号量这个名字起的令人莫名其妙,但是看其英文原意,就十分容易理解。
    semaphore 英[ˈseməfɔ:(r)] vt. 发出信号,打旗语;
    类似于指挥官的作用。
    下面我们看下一个伪代码信号量的使用。

    1、创建信号量唯一标识符
    $ftok = ftok(__FILE__, 'a');

    2、创建信号量资源ID
    $sem_resouce_id = sem_get($ftok);

    3、接受信号量
    sem_acqure($sem_resource_id);

    4、释放信号量
    sem_release($sem_resource_id);

    5、销毁信号量
    sem_remove($sem_resource_id);

    举个不文雅的例子,使我们容易理解这个信号量在生活中的用法。理解之后可以套用到我们编程领域。
    一家公司只有一个卫生间。那么当有人上厕所的时候,都要获取一把锁(信号量),表示卫生间正在使用。代码如下:

    sem_acqure($sem_resource_id);

    那么员工上完厕所之后,就需要将锁打开,释放锁(信号量),表示现在可以允许别人使用。代码如下:

    sem_release($sem_resource_id);

    通过一个简单的锁,我们就能够知道当前的厕所(共享内存)是否可以使用。这个例子不雅观,但说明了问题。这篇博客也是有味道的博客,真是不容易。。。。以下是示例代码:

    <?php
    //创建共享内存区域
    $shm_key = ftok(__FILE__, 'a');
    $shm_id = shm_attach($shm_key, 1024, 0755);

    //var_dump($shm_id);die(); resource(4) of type (sysvshm)
    const SHARE_KEY = 1;
    $child_list = [];

    //加入信号量
    $sem_id = ftok(__FILE__, 'b');
    $signal = sem_get($sem_id);

    //$signal resource(5) of type (sysvsem)


    for ($i = 0; $i < 3; $i++) {
    $pid = pcntl_fork();
    if ($pid == -1) {
    exit("Fork fail!".PHP_EOL);
    } elseif ($pid == 0) {
    //获取信号量
    sem_acquire($signal);
    if (shm_has_var($shm_id,SHARE_KEY)) {
    $count = shm_get_var($shm_id, SHARE_KEY);
    $count++;
    //模拟业务处理
    $sec = rand(1, 3);
    sleep($sec);
    shm_put_var($shm_id, SHARE_KEY, $count);
    } else {
    $count = 0;
    $sec = rand(1, 3);
    sleep($sec);
    shm_put_var($shm_id, SHARE_KEY, $count);
    }

    echo "child process: ".getmypid()." is writing! now count is: $count ".PHP_EOL;

    //释放信号量
    sem_release($signal);
    exit("child process".getmypid()."end".PHP_EOL);
    } else {
    $child_list[] = $pid;
    }
    }

    while (count($child_list) > 0) {
    foreach ($child_list as $key => $pid) {
    $status = pcntl_waitpid($pid, $status);
    if ($status > 0 || $status == -1) {
    unset($child_list[$key]);
    }
    }
    sleep(1);
    }

    $count = shm_get_var($shm_id, SHARE_KEY);
    echo " $count ".PHP_EOL;

    //销毁信号量
    sem_remove($signal);

    shm_remove($shm_id);
    shm_detach($shm_id);
  • 相关阅读:
    atitit...触发器机制 ltrigger mechanism sumup .的总结O8f
    atitit. 集合groupby 的实现(2)---自定义linq查询--java .net php
    atitit. groupby linq的实现(1)-----linq框架选型 java .net php
    atitit.j2ee 1.5 1.6 的不同跟 Servlet 3.0新特性总结
    Atitit. 常用街机系统and 模拟器总结 snk neo geo cps mame sfc smc
    atitit. access token是什么??微信平台公众号开发access_token and Web session保持状态机制
    atitit.二进制数据无损转字符串网络传输
    atitit.压缩算法 ZLib ,gzip ,zip 最佳实践 java .net php
    Atitit.现实生活中最好使用的排序方法-----ati排序法总结
    atitit.修复xp 操作系统--重装系统--保留原来文件不丢失
  • 原文地址:https://www.cnblogs.com/roverliang/p/6246963.html
Copyright © 2011-2022 走看看