PHP 7.0.6 Released

    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.

    Warning

    The programmer must retain references to stacked objects until they are executed or unstacked; the Pool class provides a higher level abstraction of the Worker functionality and manages references for the programmer.

    Class synopsis

    Worker extends Thread implements Traversable , Countable , ArrayAccess {
    /* Methods */
    public integer getStacked ( void )
    public boolean isShutdown ( void )
    public boolean isWorking ( void )
    public boolean shutdown ( void )
    public integer stack ( Threaded &$work )
    public integer unstack ([ Threaded &$work ] )
    /* Inherited methods */
    public void Thread::detach ( void )
    public integer Thread::getCreatorId ( void )
    public static Thread Thread::getCurrentThread ( void )
    public static integer Thread::getCurrentThreadId ( void )
    public integer Thread::getThreadId ( void )
    public static mixed Thread::globally ( void )
    public boolean Thread::isJoined ( void )
    public boolean Thread::isStarted ( void )
    public boolean Thread::join ( void )
    public void Thread::kill ( void )
    public boolean Thread::start ([ integer $options ] )
    }

    Table of Contents

    User Contributed Notes

    event2game at gmail dot com
    2 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();
    To Top