PHP 멀티스레딩은 다중 프로세스 크로스 플랫폼 코드 예제를 구현합니다.

define('DIR_PHP_EXEC', 'php');
define('DIR_MAIN_EXEC', __FILE__ );
define('DIR_TMP', '/tmp');
require_once('my_process.php');
class pp extends my_process_base {
public function run($param = null) {
 for ($i = 0; $i < 4; $i ) {
 echo "111 $paramn";
 sleep(1);
 }
}
}
init_my_process();
$obj = $GLOBALS['gal_obj_process_m'];
if ($obj->is_main ()) {
$obj->run_task('pp', 'a');
$obj->run_task('pp', 'b');
$obj-> run_task('pp', 'c');
$obj->run_task('pp', 'd');
//$obj->run_task('pp', 'b') ;
$obj->set_max_run(10);
$obj->run();
}?>

2, 프로세스 관리 수업

/**
* @copyright 2007 movi
* @author 徐智 *
* $Id: getPage.php 11 2007-09-21 02:15:01Z fred $
* 수정 by bbs.it- home.org
*/
if (!definition('DIR_PHP_EXEC')) 정의('DIR_PHP_EXEC', 'php');
//if (!define('DIR_MAIN_EXEC')) 정의('DIR_MAIN_EXEC', '');
if (!defined('DIR_TMP')) 정의 ('DIR_TMP', '');
/********/
/* 初始化 */
define('CMD_MAIN_PROCESS_KEY', 'main_process_key');
define('CMD_CHILD_PROCESS_NAME' , 'child_process_name');
define('CMD_CHILD_PROCESS_PARAM', 'child_process_param');
function init_my_process() {
$GLOBALS['gal_obj_cmd'] = new my_cmd_argv ();
$key = $GLOBALS['gal_obj_cmd']->get_value(CMD_MAIN_PROCESS_KEY);
$key = $key === false ? '' : $key;
$GLOBALS['gal_obj_process_m'] = new my_process_m($key);
if (!$GLOBALS['gal_obj_process_m']->is_main()) $GLOBALS['gal_obj_process_m' ]->run() ;
}
/**
* PHP 다중 프로세스 클래스
*
* 이 객체에서 상속한 다음 자체 실행 처리를 구현해야 합니다
*/
추상 클래스 my_process_base {
공용 함수 __construct($auto_run=true , $name='') {
}
공개 함수 __destruct() {
 echo "@endn";
}
추상 공용 함수 run($param = null);
}

class my_cmd_argv {
private $cmd_argv = array();
공용 함수 __construct() {
 $argv = $_SERVER['argv'];
 for ($i = 1; $i < count($argv); $i ) {
 $ cmd = 폭발('=', $argv[$i]);
 $this->cmd_argv[$cmd[0]] = isset($cmd[1]) ? $cmd[1] : '';
 }
}
public function get_key($key) {
 return isset($this->cmd_argv[ $key]);
}
public function get_value($key) {
 return isset($this->cmd_argv[$key]) ? $this->cmd_argv[$key] : false;
}
}
/**
* PHP 다중 프로세스 관리 클래스
* 다중 프로세스 처리는 PHP에서 구현 가능하며 콘솔 모드에서만 사용할 수 있습니다.
* 현재 신호 구현 메커니즘은 파일 모드를 사용합니다
*
*/
class my_process_m {
 /**
 * @var array $task_list
 * 프로세스 목록
*/
비공개 $task_list = array();
비공개 $lock_list = array();
비공개 $lock = null;
비공개 $is_main = false;
private $max_run = 3600000;
private function release_lock($key = null) {
 $lock = &$this->lock_list;
 if (!is_null ($key)) {
 $key = md5($this->build_lock_id($key));
 if (isset($lock[$key])) {
 if (is_resource($ 잠금[$key][0])) fclose($lock[$key][0]);
 unlink($lock[$key][1]);
 unset($lock[$key] );
 }
 true를 반환합니다.
 }
       foreach ($lock as $k => $h) {
 if (is_resource($h)) fclose($h);
 unset($lock[$k]);
 }
 return true;
}
비공개 함수 release_task($key = null) {
 $task = &$this->task_list;
 if (! is_null($key) && isset($task[$key])) {
 if (is_resource($task[$key])) pclose($task[$key]);
 unset($task[ $key]);
 } else {
 foreach ($task as $k => $h) {
 if (is_resource($h)) pclose($h);
 unset( $task[$k]);
 }
 }
 return true;
}

private function build_lock_id($key) {
 return DIR_TMP . DIRECTORY_SEPARATOR. $키 . '_sem.lock';
}
보호 함수 run_child_process() {
 $class = $GLOBALS['gal_obj_cmd']->get_value(CMD_CHILD_PROCESS_NAME);
 $param = $GLOBALS['gal_obj_cmd']->get_value(CMD_CHILD_PROCESS_PARAM);
 $param = $param == '' ? null : unserialize(base64_decode(trim($param)));
 $obj = new $class();
 $obj->run($param);
 $this->task_list[ ] = $obj;
}
공개 함수 __construct($lock='') {
 if ($lock === '') {
 $ this->is_main = true;
 $key = md5(uniqid()) . '_main.my_process';
 $lock = array($key, $this->get($key));
 } else {
 $this->is_main = false;
 $lock = array($lock, 0);
 }
 $this->lock = $lock;
}
public 함수 __destruct() {
 $this->release_lock();
 $this->release_task();
}
/**
 * 모든 프로세스 중지
 *
*/
공개 함수 stop_all() {
}
/**
 * 메인공정인지
 *
*/
공개 함수 is_main() {
 return $this->is_main;
}
/**
 * 이미 활성 신호가 있습니까?
 *
 * @param string $key
 * @return bool
*/
공용 함수 존재($key) {
 return file_exists($this->build_lock_id($key));
}
/**
 * 신호 받기
 *
 * @param string $key
 * @param int $max_acquire 차단된 요청의 최대 수
 * @return mix 성공하면 신호 ID를 반환합니다.
 *
*/
공용 함수 get($key, $max_acquire=5) {
 $fn = $this->build_lock_id($key);
 if (isset($this->lock_list[md5($fn)])) return false;
 $id = fopen($fn, 'a ');
 if ($id) $ this->lock_list[md5($fn)] = array($id, $fn);
 return $id;
}
/**
 * 신호 해제
 *
 * @param string $key
 * @return bool 성공하면 신호 true 반환
 *
*/
공용 함수 제거($key) {
 return $this->release_lock($key);
}
/**
 * 신호 받기
 *
 * @param string $id 신호 ID
 * @param bool $block 차단 여부
*/
공용 함수 획득($id, $block=false) {
 if ($block) {
 return Flock($id, LOCK_EX);
 } else {
 return Flock($id, LOCK_EX LOCK_NB);
 }
}
/**
 * 신호 해제
 *
*/
공개 기능 해제($id) {
 Flock($id, LOCK_UN);
}
공용 함수 run_task($process_name, $param=null) {
 $this->task_list[] = popen(DIR_PHP_EXEC . ' -f ' . DIR_MAIN_EXEC . ' -- '
 . CMD_CHILD_PROCESS_NAME. '=' . $프로세스_이름 . ' '
 . CMD_CHILD_PROCESS_PARAM . '="' . base64_encode(serialize($param)) . '" '
 . CMD_MAIN_PROCESS_KEY . '="' . $this->lock[0] . '" ',
 'r');
}
공용 함수 run($auto_run = true) {
 if ($this->is_main) {
 $ps = &$this->task_list;
 $max_run = &$this->max_run;
 $id = 0;
 do {
 //echo "프로세스-------------: n";
 $c = 0;
 foreach($ps를 $k로 => $h) {
 $c ;
 $msg = fread($h, 8000);
 if (substr($msg, -5, 4) === '@end') {
 echo "프로세스 종료:[$k][$id] echo n{$msg} n";
 $this->release_task($k);
 } else {
 echo "프로세스:[$k][$id] echo n{$msg} n";
 }
 }
 sleep(1);
 } while ($auto_run && $id < $ max_run && $c > 0);
 } else {
 $this->run_child_process();
 }
}
공용 함수 set_max_run ($max=1000) {
 $this->max_run = $max;
}
}
?>