The Worker class

    (PECL pthreads >= 2.0.0)

    Introduction

    Worker Threads have a persistent context, as such should be used over Threads in most cases.

    When a Worker is started, the run method will be executed, but the Thread will not leave until one of the following conditions are met:

    • the Worker goes out of scope (no more references remain)

    • the programmer calls shutdown

    • the script dies

    This means the programmer can reuse the context throughout execution; placing objects on the stack of the Worker will cause the Worker to execute the stacked objects run method.

    Class synopsis

    class Worker extends Thread implements Traversable, Countable, ArrayAccess {
    /* Methods */
    public collect(Callable $collector = ?): int
    public getStacked(): int
    public isShutdown(): bool
    public shutdown(): bool
    public stack(Threaded &$work): int
    public unstack(): int
    /* Inherited methods */
    public Thread::getCreatorId(): int
    public static Thread::getCurrentThread(): Thread
    public static Thread::getCurrentThreadId(): int
    public Thread::getThreadId(): int
    public Thread::isJoined(): bool
    public Thread::isStarted(): bool
    public Thread::join(): bool
    public Thread::start(int $options = ?): bool
    }

    Table of Contents

    Improve This Page

    Learn How To Improve This Page • Submit a Pull Request • Report a Bug
    ＋add a note

    User Contributed Notes 1 note

    up
    -9
    event2game at gmail dot com
    10 years ago
    There's one way to shared datas between Workers, that is using Stackable:
    <?php
    class data extends Stackable{
    //private $name;
    public function __construct($_name) {
    //$this->name = $_name;//if you set any variable, workers will get the variable, so do not set any variable
    echo __FILE__.'-'.__LINE__.'<br/>'.chr(10);
    }
    public function     run(){
    echo     __FILE__.'-'.__LINE__.'<br/>'.chr(10);
    }
    }
    class     readWorker extends Worker {
    public function     __construct(&$_data) {
    $this->data = $_data;//
    }
    public function     run(){
    while(    1){
    if(    $arr=$this->data->shift())//receiving datas
    {
    echo     'Received data:'.print_r($arr,1).chr(10);
    }else     usleep(50000);
    }
    }
    }
    class     writeWorker extends Worker {
    public function     __construct(&$_data) {
    $this->data = $_data;//
    }
    public function     run(){
    while(    1){
    $this->data[] = array(time(),rand());//writting datas
    usleep(rand(50000, 1000000));
    }
    }

    }
    $data = new data('');
    $reader = new readWorker($data);
    $writer = new writeWorker($data);
    $reader->start();
    $writer->start();
    ?>
    Also you can use $readWorker[] = $some_data; then use $this->shift() in readWorker to share datas with readWorker, but if you do so you can't have variables in readWorker as all variales will be shift by shift();
    ＋add a note
    To Top