<?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结果：012367891045$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