Threaded::notify

    (PECL pthreads >= 2.0.0)

    Threaded::notify — 同步

    描述

    public Threaded::notify(): bool

    向引用的对象发送通知

    参数

    此函数没有参数。

    返回值

    成功时返回 true，失败时返回 false。

    范例

    范例 #1 通知和等待

    <?php
    class My extends Thread {
    public function     run() {
    /** 使此线程等待 **/
    $this->synchronized(function($thread){
    if (!    $thread->done)
    $thread->wait();
    },     $this);
    }
    }
    $my = new My();
    $my->start();
    /** 向等待的线程发送通知 **/
    $my->synchronized(function($thread){
    $thread->done = true;
    $thread->notify();
    },     $my);
    var_dump($my->join());
    ?>

    上面的例子将输出

    bool(true)

    改进此页面

    了解如何改进此页面 • 提交拉取请求 • 报告错误
    ＋添加注释

    用户贡献的注释 1 个注释

    -4
    cottton at i-stats dot net
    9 年前
    似乎有些运算符不起作用。
    例如，$thread->array[] = 1; 失败

    一个简单的测试
    <?php
    class My extends Thread
    {
    public
    $array = array('default val 1', 'default val 2'),
    $msg = 'default',
    $stop = false;

    public function     run()
    {
    while(    true)
    {
    echo     $this->msg . PHP_EOL;
    if(    count($this->array) > 0){
    foreach(    $this->array as $val){
    var_dump($val);
    }
    $this->array = array();
    }
    /** 使此线程等待 **/
    $this->synchronized(
    function(    $thread){
    if(    count($this->array) < 1){
    $thread->wait();
    }
    },
    $this
    );
    echo     PHP_EOL;
    if(    $this->stop){
    break;
    }
    }     // while
    }
    }
    $my = new My();
    $my->start();

    sleep(1); // 等待一下

    // 测试 1 - $thread->array[] = 1;
    $my->synchronized(
    function(    $thread){
    $thread->msg = 'test 1';
    $thread->array[] = 1;
    $thread->notify();
    },
    $my
    );

    sleep(1); // 等待一下

    // 测试 2 - array_push($thread->array, 2);
    $my->synchronized(
    function(    $thread){
    $thread->msg = 'test 2';
    array_push($thread->array, 2);
    $thread->notify();
    },
    $my
    );

    sleep(1); // 等待一下

    // 测试 3 - array_push($thread->array, 2);
    $my->synchronized(
    function(    $thread){
    $thread->msg = 'test 3';
    $new = array(3);
    $thread->array = array_merge($thread->array, $new);
    $thread->notify();
    },
    $my
    );

    sleep(1); // 等待一下

    $my->stop = true;
    ?>
    out
    default
    string(13) "default val 1"
    string(13) "default val 2"

    test 1

    test 2

    test 3
    int(3)

    所以在这个例子中只有 array_merge() 工作了。
    ＋添加注释
    To Top