Worker 类

(PECL pthreads >= 2.0.0)

简介

Worker 是一个具有持久化上下文的线程对象，通常用来在多个线程中使用。

当一个 Worker 对象开始之后，会执行它的 run 方法，但是即使 run 方法执行完毕，线程本身也不会消亡，除非遇到以下情况：

Worker 对象超出作用范围（没有指向它的引用了）
代码调用了 Worker 对象的 shutdown 方法
整个脚本终止了

这意味着程序员可以在程序执行过程中重用这个线程上下文：在 Worker 对象的栈中添加对象会激活 Worker 对象执行被加入对象的 run 方法。

类摘要

Worker extends Thread implements Traversable , Countable , ArrayAccess {

/* 方法 */

public collect ( Callable $collector = ? ) : int

public getStacked ( ) : int

public isShutdown ( ) : bool

public shutdown ( ) : bool

public stack ( Threaded &$work ) : int

public unstack ( ) : int

/* 继承的方法 */

public Thread::getCreatorId ( ) : int

public static Thread::getCurrentThread ( ) : Thread

public static Thread::getCurrentThreadId ( ) : int

public Thread::getThreadId ( ) : int

publicThread::isJoined ( ) : bool

publicThread::isStarted ( ) : bool

publicThread::join ( ) : bool

public Thread::start ( int $options = ? ) : bool

}

Worker::collect — Collect references to completed tasks
Worker::getStacked — 获取剩余的栈大小
Worker::isShutdown — 状态检测
Worker::shutdown — 关闭 Worker
Worker::stack — 将要执行的任务入栈
Worker::unstack — 将要执行的任务出栈

User Contributed Notes

event2game at gmail dot com 31-Oct-2013 03:22


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();

Worker 类

简介

类摘要

Table of Contents

User Contributed Notes