php_PHP チュートリアルでのマルチスレッドの実装-PHPチュートリアル-php.cn

php_PHP チュートリアルでのマルチスレッドの実装

WBOY

リリース： 2016-07-20 11:07:00

オリジナル

1235 人が閲覧しました

phpはマルチスレッドを実装します
マルチプロセスを実装するには、サーバーが複数のリクエストを送信する方がはるかに便利です。 cli モードでのみ使用できます。メール送信業務など特別な場面でご利用いただけます。
リソースへの共有アクセスにはファイルロックが使用されますが、これは主に Windows で使用するためのものであり、本当に必要な場合は、対応するセマフォメカニズムを自分で使用することを検討できます (この拡張機能は xUNIX でのみ使用できます)。

例
[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 , '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();
}

[/php]

プロセス管理クラス
[php]
/**
* @copyright 2007 movivi
* @author 徐智
*

* $Id: getPage.php 11 2007-09-21 02:15:01Z fred $

if (!define('DIR_PHP_EXEC'))define('DIR_PHP_EXEC', 'php');

//if ( !define('DIR_MAIN_EXEC'))define( 'DIR_MAIN_EXEC', '');
if (!define('DIR_TMP'))define('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_ar gv() ;
$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();
public function __construct() {
$argv = $_SERVER['argv'];

for ( $i = 1; $i $cmd =explode('=', $argv[$i]);
) ? $cmd[1] : '';

}

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
* プロセスリスト
*/

private $task_list = array();

private $lock_list = array();
private $lock = null;
private $is_main = false;
プライベート $max_run = 3600000;

プライベート関数 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($lock[$key][0])) fclose($lock[$key][0]);
unlink($lock) [$key][1]);
unset($lock[$key]);
}
return true;
}

foreach ($lock as $k => $h) {
if (is_resource($ h)) fclose($h);
unset($lock[$k]);
}
return true;
}

private function 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;
}

プライベート関数 build_lock_id($key) {
return DIR_TMP 。 DIRECTORY_SEPARATOR 。 $key 。 '_sem.lock';
}

保護関数 run_child_process() {
$class = $GLOBALS['gal_obj_cmd']->get_value(CMD_CHILD_PROCESS_NAME);
$param = $GLOBALS['gal_obj_cmd']- > 値の取得(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 function __destruct() {
$this->release_lock();
$this-> ;release_task();
}

/**
* すべてのプロセスを停止します
*
*/
パブリック関数 stop_all() {
}

/**
* メインプロセスですか
*/
public function is_main() {
return $this->is_main;
}

/**

* アクティブな信号は既にありますか
**/
public function assign($key) {
return file_exists( $this->build_lock_id($key));
}

/**信 * シグナルを取得します
*
@param String $ Key

* @param int $ Max_acquire 番号をブロックする最大リクエスト

@Return mix*/
public function 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*/
public function Remove($key) {
return $this- >release_lock($key);

}

/**
* シグナルを取得する
*
* @param string $id シグナルID
* @param bool $block ブロックするかどうか
*/
public functionacquire($id, $block=false) {
if ($block) {
return flock($id, LOCK_EX) ;

} else {

return flock($id, LOCK_EX + LOCK_NB);
}
}

/**
* 信号を放す
*
*/
public function release($id) {
flock($id, LOCK_UN);
}
public function 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');
}

public function 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 as $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 "process:[$k][$id] echo n{$msg} n";
}
sleep(1);
} while ($auto_run && $id++ < $max_run && $ c > 0);
} else {
$this->run_child_process();
}
}