<?phpclass test extends Thread {public function __construct($arg){$this->arg = $arg;}public function run(){if($this->arg){sleep(3);printf("Hello %s\n", $this->arg);}}
}
$thread = new test("World");$thread->start();echo "main thread\r\n";
?>

<?php
class test extends Thread {private $name = '';private $res = null;public function __construct($name, $res){$this->name = $name;$this->res = $res;}public function run(){while(!feof($this->res)) {if(flock($this->res, LOCK_EX)) {$data = fgets($this->res);$data = trim($data);echo "Thread {$this->name} Read {$data} \r\n";sleep(1);flock($this->res, LOCK_UN);}}}
}$fp = fopen('./test.log', 'rb');$threads[] = new test('a', $fp);
$threads[] = new test('b', $fp);foreach($threads as $thread) {$thread->start();
}foreach($threads as $thread) {$thread->join();
}
?>

111111
222222
333333
444444
555555
666666

<?php
class Total extends Thread {public $name = '';private $total = 0;private $startNum = 0;private $endNum = 0;public function __construct($name, $startNum, $endNum){$this->name = $name;$this->startNum = $startNum;$this->endNum = $endNum;}public function run(){for($ix = $this->startNum; $ix < $this->endNum; ++$ix) {$this->total += $ix;}echo "Thread {$this->name} total: {$this->total} \r\n";}public function getTotal() {return $this->total;}
}$num = 10000000;
$threadNum = 10;
$setp = $num / $threadNum;
$startNum = 0;$startTime = microtime(true);
for($ix = 0; $ix < $threadNum; ++$ix) {$endNum = $startNum + $setp;$thread = new Total($ix, $startNum, $endNum);$thread->start();$startNum = $endNum;$threads[] = $thread;
}$total = 0;
foreach($threads as $thread) {$thread->join();$total += $thread->getTotal();
}$endTime = microtime(true);
$time = $endTime - $startTime;echo "total : {$total} time : {$time} \r\n";