ホームページ >バックエンド開発 >PHPチュートリアル >PHP マルチスレッド拡張機能 (シリアス スレッド) pthreads インストール_PHP チュートリアル
环境CentOS 6.3 64bit,php 5.4.5
<?php /* * Sharing symbols 101 * @NOTE Thread::fetch was never included in a release and was superceeded by object handlers * pthreads allows read access to thread data from any context pthreads allows write access to thread data from any context carry on reading ... work in progress ... */ class TestObject { public $val; } class Fetching extends Thread { public function run(){ /* * of course ... */ $this->sym = 10245; $this->arr = array( "1", "2", "3" ); echo '6'.chr(10); /* * objects do work, no preparation needed ... * read/write objects isn't finalized .. * so do the dance to make it work ... */ $obj = new TestObject(); $obj->val = "testval"; $this->obj = $obj; echo '7'.chr(10); /* * will always work */ $this->objs = serialize($this->obj); echo '8'.chr(10); /* * nooooooo */ $this->res = fopen("php://stdout", "w"); echo '9'.chr(10); /* * tell the waiting process we have created symbols and fetch will succeed */ $this->synchronized(function(){ $this->notify(); }); echo '10'.chr(10); /* wait for the process to be finished with the stream */ $this->synchronized(function(){ $this->wait(); }); echo '11'.chr(10); } } echo '0'.chr(10); $thread = new Fetching(); echo '1'.chr(10); $thread->start(); //sleep(1); 加了这个就不能正常工作,真奇怪 echo '2'.chr(10); $thread->synchronized(function($me){ echo '3'.chr(10); $me->wait(); echo '4'.chr(10); }, $thread); echo '5'.chr(10); /* * we just got notified that there are symbols waiting */ foreach(array("sym", "arr", "obj", "objs", "res") as $symbol){ printf("\$thread->%s: ", $symbol); $fetched = $thread->$symbol; if ($fetched) { switch($symbol){ /* * manual unserialize */ case "objs": var_dump(unserialize($fetched)); break; default: var_dump($fetched); } } printf("\n"); } /* notify the thread so it can destroy resource */ $thread->synchronized(function($me){ $me->notify(); }, $thread); ?> /usr/local/php-zts/bin/php Fetch.php 结果: 0 1 2 3 6 7 8 9 10 4 5 $thread->sym: int(10245) $thread->arr: array(3) { [0]=> string(1) "1" [1]=> string(1) "2" [2]=> string(1) "3" } $thread->obj: object(TestObject)#2 (1) { ["val"]=> string(7) "testval" } $thread->objs: object(TestObject)#2 (1) { ["val"]=> string(7) "testval" } $thread->res: resource(3) of type (stream) 11