PHP pthreads学习笔记

 1 <?php
 2 class HelloWorld extends Thread {
 3     public function __construct($world) {
 4        $this->world = $world;
 5     }   
 6 
 7     public function run() {
 8         print_r(sprintf("Hello %s\n", $this->world));
 9         sleep(1);
10     }   
11 }
12 
13 for ($i=0; $i<10; $i++) {
14     $pool[] = new HelloWorld(‘world‘ . $i);
15 }
16 
17 foreach ($pool as $work) {
18     $work->start();
19 }

<?php
class HelloWorld extends Thread
{
    private $_data;

    public function __construct($data) {
       $this->_data = $data;
    }   

    public function run() {
        $this->_data[] = Thread::getCurrentThreadId();
        sleep(1);
    }   
}

class Storage extends Stackable
{
    public function run(){}
}
$storage = new Storage();

for ($i=0; $i<10; $i++) {
    $pool[] = new HelloWorld($storage);
}

foreach ($pool as $work) {
    $work->start();
}

print_r($storage);