|
<?php error_reporting(E_ALL); set_time_limit(0); printf( "<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<br />"); /** * php多任務(wù)程序的實現(xiàn) * 借助proc_open * 其實該叫進(jìn)程(process) * 能啟動多進(jìn)程，你可以使用你的想象力做你想做的了，以后再寫個能用的 * 如果你是在linux上跑php，并且啟用pcntl模塊后，使用pcntl函數(shù)該更好 * * 在網(wǎng)上搜索很多關(guān)于php多任務(wù)的，中文的很難找到一個，找到的也多是瞎扯蛋 */ class Thread { protected $_pref; // process reference protected static $_instance = null; protected $_pipes; private function __construct() { $this->_pref = 0; } public static function getInstance($file) { if (null == self::$_instance) { self::$_instance = new self; } $descriptor = array( 0 => array("pipe", "r"), 1 => array("pipe", "w"), 2 => array("file", "./error-output.txt", "a"), ); self::$_instance->_pref = proc_open("php -q $file", $descriptor, self::$_instance->_pipes); return true; } public function __destruct() { proc_close($this->_pref); $this->_pref = null; } } // 測試代碼 $file = __FILE__; if(empty($argv[1])) { $t2 = Thread::getInstance("$file 1"); $t3 = Thread::getInstance("$file 2"); $t4 = Thread::getInstance("$file 3"); $t5 = Thread::getInstance("$file 4"); $t5 = Thread::getInstance("$file 5"); $t5 = Thread::getInstance("$file 6"); $t2 = Thread::getInstance("$file 7"); $t3 = Thread::getInstance("$file 8"); $t4 = Thread::getInstance("$file 9"); $t5 = Thread::getInstance("$file 10"); $t5 = Thread::getInstance("$file 11"); $t5 = Thread::getInstance("$file 12"); echo "Main thread done\n"; } else { $somecontent = "\r\n//~~~~~~~~~~~~-這次請求序號是：" . $argv[1]; sleep(mt_rand(0, 3)); $handle = fopen($file, 'a+'); fwrite($handle, $somecontent); } ?>
|
|
|
