首页 / PHP / php多线程实现多进程跨平台的一例代码

php多线程实现多进程跨平台的一例代码

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了php多线程实现多进程跨平台的一例代码，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含6527字，纯文字阅读大概需要10分钟。

内容图文

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 $param\n";
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 movivi
* @author 徐智 *
* $Id: getPage.php 11 2007-09-21 02:15:01Z fred $
* modify by bbs.it-home.org
*/
if (!defined('DIR_PHP_EXEC')) define('DIR_PHP_EXEC', 'php');
//if (!defined('DIR_MAIN_EXEC')) define('DIR_MAIN_EXEC', '');
if (!defined('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_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多进程类
*
* 你需要从这个对象继承，然后实现你自己的run处理
*/
abstract class my_process_base {
public function __construct($auto_run=true, $name='') {
}
public function __destruct() {
echo "@end\n";
}
abstract public function run($param = null);
}
class my_cmd_argv {
private $cmd_argv = array();
public function __construct() {
$argv = $_SERVER['argv'];
for ($i = 1; $i < count($argv); $i++) {
$cmd = explode('=', $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
* 进程列表
*/
private $task_list = array();
private $lock_list = array();
private $lock = null;
private $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($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;
}
private function build_lock_id($key) {
return DIR_TMP . DIRECTORY_SEPARATOR . $key . '_sem.lock';
}
protected function 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;
}
public function __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();
}
/**
* 停止所有进程
*
*/
public function stop_all() {
}
/**
* 是否是主进程
*
*/
public function is_main() {
return $this->is_main;
}
/**
* 是不是已经存在一个活动信号
*
* @param string $key
* @return bool
*/
public function exist($key) {
return file_exists($this->build_lock_id($key));
}
/**
* 获取一个信号
*
* @param string $key
* @param int $max_acquire 最大请求阻塞数量
* @return mix 如果成功返回一个信号ID
*
*/
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
* @return bool 如果成功返回一个信号true
*
*/
public function remove($key) {
return $this->release_lock($key);
}
/**
* 获取一个信号
*
* @param string $id 信号ID
* @param bool $block 是否阻塞
*/
public function acquire($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 . '=' . $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 "process-------------: \n";
$c = 0;
foreach ($ps as $k => $h) {
$c++;
$msg = fread($h, 8000);
if (substr($msg, -5, 4) === '@end') {
echo "end process:[$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();
}
}
public function set_max_run($max=1000) {
$this->max_run = $max;
}
}
?>

内容总结

以上是互联网集市为您收集整理的php多线程实现多进程跨平台的一例代码全部内容，希望文章能够帮你解决php多线程实现多进程跨平台的一例代码所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/162674.html

来源：【匿名】

【上一篇】phpcurlpost的简单示例【下一篇】PHP 5 数据对象 (PDO) 抽象层与 Oracle

更多 ►

【php多线程实现多进程跨平台的一例代码】教程文章相关的互联网学习教程文章

PHPCurl多线程实现原理与实例详解_PHP教程

因为工作中我们经常会需要使用到Curl多线程来处理一些事情，不得己就深入了对Curl多线程研究了，下面小编来给各位同学介绍一下Curl多线程实例与原理吧。相信许多人对php手册中语焉不详的curl_multi一族的函数头疼不已，它们文档少，给的例子更是简单的让你无从借鉴，我也曾经找了许多网页，都没见一个完整的应用例子。 curl_multi_add_handle curl_multi_close curl_multi_exec curl_multi_getcontent curl_multi_info_read ...

php多线程怎么实现【图】

PHP默认并不支持多线程，要使用多线程需要安装pthread扩展，而要安装pthread扩展，必须使用--enable-maintainer-zts参数重新编译PHP，这个参数是指定编译PHP时使用线程安全方式。PHP 实现PHP 实现的线程安全主要是使用 TSRM 机制对全局变量和静态变量进行了隔离，将全局变量和静态变量给每个线程都复制了一份，各线程使用的都是主线程的一个备份，从而避免了变量冲突，也就不会出现线程安全问题。（推荐学习：PHP视频教程）PHP 对...

PHP中多线程的实现方法

多线程是java中一个很不错的东西，很多朋友说在php中不可以使用PHP多线程了，其实那是错误的说法，本文就是介绍PHP中多线程的两个实现方法，有兴趣的同学可以看一下。PHP本身是不是支持多线程的，不过我们可以借助其他的方法来实现多线程，比如 shell 服务，比如 web 服务器，本文我们来讲讲这两个方法如何实现。需要的朋友可以来参考一下。多线程是java中一个很不错的东西，很多朋友说在php中不可以使用PHP多线程了，其实那是错误...

PHP使用curl多线程实现抓取网页功能

本文主要和大家分享PHP使用curl多线程抓取网页功能，CURL 支持多线程的抓取网页的功能，代码例子如下。希望能帮助到大家。class HttpMulti {//curl选项private static $options = array(CURLOPT_SSL_VERIFYPEER => 0, //不开启HTTPS请求CURLOPT_RETURNTRANSFER => 1, //请求信息以文件流方式返回CURLOPT_CONNECTTIMEOUT => 10, //连接超时时间默认为10sCURLOPT_TIMEOUT => 20, //设置curl执行最大时间CURLOPT_ENCODING => "...

php多线程的实现实例

php多线程对于很多刚刚接触php的小伙伴们来说有点不明白是意思，干什么用的，那么我们今天就带大家讲解下php多线程的实现案例！假设我们现在运行的是a.php这个文件. 但是我在程序中又请求WEB服务器运行另一个b.php那么这两个文件将是同时执行的.(PS: 一个链接请求发送之后, WEB服务器就会执行它, 而不管客户端是否已经退出)有些时候, 我们想运行的不是另一个文件, 而是本文件中的一部分代码.该怎么办呢?其实可是通过参数来控制a.ph...

php多线程实现方法及用法实例详解

下面我们来介绍具体php多线程实现程序代码，有需要了解的同学可参考。当有人想要实现并发功能时，他们通常会想到用fork或者spawn threads，但是当他们发现php不支持多线程的时候，大概会转换思路去用一些不够好的语言，比如perl。其实的是大多数情况下，你大可不必使用fork 或者线程，并且你会得到比用fork 或thread 更好的性能。假设你要建立一个服务来检查正在运行的n台服务器，以确定他们还在正常运转。你可能会写下面这样的代码...

用php写sokket连接第三方服务器，要保持连接不断，每三分钟向对方发一次心跳，php是单线程的，这个怎么才能实现呢？

业务流程是这样的，我们php服务器用socket连接对方服务器，对方服务器会不定时的发消息给我们php服务器，所以我们php需要一直read，read的同时还需要每三分钟发一次心跳给对方，当php一直在read，对方没有消息发过来的时候，php一直在等，怎么才能保证每三分钟发一次心跳？回复内容：业务流程是这样的，我们php服务器用socket连接对方服务器，对方服务器会不定时的发消息给我们php服务器，所以我们php需要一直read，read的同时还需...

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 echo "111 $param\n"; 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');...

CURL的学习和应用(附多线程实现)_PHP教程【图】

curl安装：windows下面的安装：修改php.ini文件的设置，找到php_curl.dll//取消下在的注释extension=php_curl.dll linux下面安装：代码如下:# wget http://curl.haxx.se/download/curl-7.17.1.tar.gz# tar zxvf curl-7.17.1.tar.gz //解压#cd curl-7.17.1# ./configure –prefix=/usr/local/curl# make# make install这是安装php之前安装的方法.***************************phpinf查看是否加载成功！使用curl的POST数据飞信接口用...

PHP - 技术教程分类

PHP 教程 PHP 简介 PHP 安装 PHP 语法 PHP 变量 PHP echo/print PHP EOF(heredoc) PHP 数据类型 PHP 类型比较 PHP 常量 PHP 字符串 PHP 运算符 PHP If...Else PHP Switch PHP 数组 PHP 数组排序 PHP 超级全局变量 PHP While 循环 PHP For 循环 PHP 函数 PHP 魔术常量 PHP 命名空间 PHP 面向对象 PHP 测验 PHP 表单 PHP 表单验证 PHP 表单 - 必需字段 PHP 完整表单实例 PHP $_GET 变量 PHP $_POST 变量 PHP 多维数组 PHP 日期 PHP 包含 PHP 文件 PHP 文件上传 PHP Cookie PHP Session PHP E-mail PHP Error PHP Exception PHP 过滤器 PHP 7 新特性 PHP MySQL 简介 PHP MySQL 连接 PHP MySQL 创建数据库 PHP MySQL 创建数据表 PHP MySQL 插入数据 PHP MySQL 插入多条数据 PHP MySQL 预处理语句 PHP MySQL 读取数据 PHP MySQL Where PHP MySQL Order By PHP MySQL Update PHP MySQL Delete PHP ODBC AJAX 简介 AJAX PHP AJAX 数据库 AJAX 实时搜索 AJAX 投票 PHP Array PHP Calendar PHP cURL PHP Date PHP Directory PHP Error PHP Filesystem PHP Filter PHP FTP PHP HTTP PHP Mail PHP Math PHP Misc PHP MySQLi PHP PDO PHP String PHP Zip PHP Timezones PHP 图像处理 PHP RESTful PHP PCRE PHP 可用的函数 PHP Composer php 全部

PHP - 最热教程

php如何取出数组的前几个元素 PHP变量什么时候释放 PHP如何实现在数据库随机获取几条记录如何解决php base64解码乱码 php主要用于哪些领域 Laravel 批量插入(insert)数据六款国内优秀免费wordpress主题推荐 React如何从后端获取数据并渲染到前端？纯PHP实现定时器任务（Timer），php实现...php该如何安装pdo_mysql扩展

首页 / PHP / php多线程实现多进程跨平台的一例代码

php多线程实现多进程跨平台的一例代码

内容导读

内容图文

内容总结

内容备注

内容手机端

【php多线程实现多进程跨平台的一例代码】教程文章相关的互联网学习教程文章

PHPCurl多线程实现原理与实例详解_PHP教程

php多线程怎么实现【图】

PHP中多线程的实现方法

PHP使用curl多线程实现抓取网页功能

php多线程的实现实例

php多线程实现方法及用法实例详解

用php写sokket连接第三方服务器，要保持连接不断，每三分钟向对方发一次心跳，php是单线程的，这个怎么才能实现呢？

php多线程实现多进程跨平台的一例代码

CURL的学习和应用(附多线程实现)_PHP教程【图】

PHP多线程的实现方法详解_PHP教程

PHP单线程实现并行抓取网页_PHP教程

php多线程实现方法及用法实例详解，php多线程实例详解_PHP教程

PHP多线程实现技术总结

CURL的学习和应用(附多线程实现)_PHP【图】

php多线程实现方法及用法实例详解_PHP

PHP - 相关标签

多线程 - 相关标签

PHP - 技术教程分类

PHP - 最新教程

PHP - 最热教程