PHP 使用pcntl和libevent 实现Timer功能

2015-01-24信息快讯网

PHP 中实现Timer功能,中间使用到了php多线程,本文给出来pcntl的解释。

PHP 使用pcntl和libevent 实现Timer功能,先看例子,pcntl(PHP线程)解释在下面。

<?php  

function newChild($func_name) {  
    echo "enter newChild\n";  
    $args = func_get_args();  
    unset($args[0]);  
    $pid =  pcntl_fork();  
    if ($pid == 0) {  
        function_exists($func_name) and exit(call_user_func_array($func_name, $args)) or exit(-1);  
    } else if($pid == -1) {  
        echo "Couldn't create child process";  
    } else {  
        return $pid;  
    }  
}  

(PS:^_^不错的php开发交流群:256271784,验证:csl,有兴趣的话可以加入进来一起讨论)
function on_timer() {  
    echo "timer called\n";  
}  

   
/** 
 * @param $func string, function name 
 * @param $timeouts int, microtimes for time delay 
 */ 
function timer($func, $timeouts){  

   
    echo "enter timer\n";  
    $base = event_base_new();  
    $event = event_new();  

   
    event_set($event, 0, EV_TIMEOUT, $func);  
    event_base_set($event, $base);  
    event_add($event, $timeouts);  

   
    event_base_loop($base);  
}  

   
$pid = newChild("timer", "on_timer", 5000000);  

   
if ($pid > 0) {  
    echo "master process exit\n";  
}

PHP 扩展pcntl 实现 ” 多线程 ”( 进程 )
pcntl 与 ticks
ticks 是通过 declare(ticks = n) {statement} 语法定义的 , declare 语法目前只能接受 ticks, 他定义的 ticks = n 的意义是当 declare 指定的语句块中执行了 N 条低级语句去发生一个事件 , 这个事件可以通过 register_tick_function($function_name) 来注册 .
pcntl 的信号机制是基于 ticks 机制实现的 . 因此 , 我们使用 pcntl 族函数中信号相关的函数时 , 需要在前面增加 declare(ticks = n) 语法结构 .
int pcntl_alarm(int $seconds):
$seconds 秒后向进程发送一个 SIGALRM 信号 , 每次调用 pcntl_alarm 方法都会取消之前设置的时钟 .
void pcntl_exec(string $path[, array $args[, array $env]]):
在当前进程空间执行一个程序 .
$path: 必须是二进制可执行文件 , 或具有有效脚本头信息 (#!/usr/local/bin/php) 的脚本文件路径 .
$args: 将要传递给该程序的字符串参数列表 ( 数组形式 )
$envs: 环境变量 . 以数组 (key => value 形式 ) 方式传递给要执行程序的环境变量 .
int pcntl_for k (void):
创建一个子进程 , 该子进程与父进程仅仅是 PID( 进程号 ) 和 PPID( 父进程号 ) 不同 .
在父线程执行时返回创建的子进程 pid, 在子线程执行时返回 0, 创建子进程失败时会在父进程上下文返回 -1, 并引发 php 错误 .
理解这里的 fork 需要知道 : pcntl_fork 创建的是一个分支节点 , 相当于一个标记 , 父进程完成后 , 子进程会从标记处继续执行 , 也就是说 pcntl_fork 后面的代码分别被父进程和子进程执行了两遍 , 而两个进程在执行过程中得到的返回值是不同的 . 因此 , 才可以分离父子进程执行不同的代码 .
int pcntl_getpriority([int $pid = getmypid()[, int $process_identifier = PRIO_PROCESS]]):
获取给定 $pid 对应的进程的优先级 , 默认是通过 getmypid() 获取到的值也就是当前进程 .
$pid: 如果没有指定 , 默认是当前进程 .
$process_identifier: PRIO_PGRP, PRIO_USER, PRIO_PROCESS 三者之一 , 默认 PRIO_PROCESS. 其中 PRIO_PGRP 指获取进程组的优先级 , PRIO_USER 指获取用户进程的优先级 , PRIO_PROCESS 指获取特定进程优先级 .
返回进程的优先级 , 或者在发生错误时返回 false, 值越小说明越优先
bool pcntl_setpriority(int $priority[, int $pid = getmypid()[, int $process_identifier = PRIO_PROCESS]]:
设置进程的优先级 .
$priority: 优先级值 , -20 到 20 的范围内 , 默认优先级为 0.   值越小说明越优先 .
$pid: 如果没有指定 , 指当前进程
$process_identifier: 意义同 pcntl_getpriority 的 $process_identifier.
设置成功返回 TRUE, 失败返回 FALSE.
bool pcntl_signal_dispatch(void):
调用通过 pcntl_signal() 安装的即将发生的信号的处理器 .
调用成功返回 TRUE, 失败返回 false.
php 5.3.3 加入
bool pcntl_signal(int $signo, callback $handler[, bool $restart_syscalls = true]):
为指定的信号 $signo 安装一个新的信号处理器 $handler.
最后一个参数不明白意义 .
bool pcntl_sigprocmask(int $how, array $set[, array &$oldset]):
增加 , 删除或设置锁信号 , 具体的行为依赖于 $how 参数
$how: SIG_BLOCK 用于把信号增加到当前锁信号中 , SIG_UNBLOCK 用于把信号从当前锁信号中移除 , SIG_SETMASK 用于用给定的信号列表替换当前锁信号 .
$set: 要增加 , 移除或设置的信号列表 .
$oldset: 用于向调用者返回旧的锁定信号 .
成功返回 TRUE, 失败返回 FALSE.
int pcntl_sigtimedwait(array $set[, array &$siginfo[, int $seconds = 0[, int $nanoseconds = 0]]]):
pcntl_sigtimedwait 实际上和 pcntl_sigwaitinfo() 所做的是同样的事情 , 不过 pcntl_sigtimedwait 多了两个增强的参数 $seconds 和 $nanoseconds, 这样就允许脚本的停留时间有一个上限而不是无限制等待 .
$set: 需要等待的信号列表
$siginfo: 用来向调用者返回等待得到的信号的信息 , 信息内容见 pcntl_sigwaitinfo
$seconds: 超时的秒数
$nanoseconds: 超时的纳秒数
成功后 , pcntl_sigtimedwiat() 返回信号编号
int pcntl_sigwaitinfo(array $set[, array &$siginfo]):
挂起当前脚本的执行 , 直到接受到 $set 中的某个信号 , 如果其中的一个信号将要到达 ( 比如被 pcntl_sigprocmask 锁定 ) 那么 pcntl_sigwaitinfo 将会立刻返回
$set: 等待的信号列表
$siginfo: 用来向调用者返回等待得到的信号的信息 , 该信息包含以下内容 :
1.       所有信号都有以下三个信息 :
a)        signo: 信号编号
b)        errno: 错误号
c)         code: 信号代码
2.       SIGCHLD 信号特有的信息
a)        status: 退出的值或信号
b)        utime: 用户消耗时间
c)         stime: 系统消耗时间
d)        pid: 发送进程 id
e)        uid: 发送进程的真实用户 id
3.       SIGILL, SIGFPE, SIGSEGV, SIGBUS 拥有的信息
a)        addr: 产生故障的内存位置
4.       SIGPOLL 特有的信息 :
a)        band: band event, 意义未知
b)        fd: 文件描述符
函数成功运行返回信号编号
int pcntl_wait(int &$status[, int *options = 0]):
挂起当前进程直到一个子进程退出或直到一个信号要求终止当前进程或调用一个信号处理函数 . 如果子进程在调用时已经退出 ( 俗称成为了僵尸进程 ), 此函数会马上返回 , 所有的系统资源都将被释放 .
$status 用来保存子进程的状态信息 , 该状态信息由以下函数产生 : pcntl_wifexited, pcntl_wifstopped, pcntl_wifsignaled, pcntl_wexitstatus, pcntl_wtermsig, pcntl_wstopsig.
$options: 如果你的系统允许 wait3( 大多数的 BSD 类系统 ), 你可以提供一个可选的 options 参数 , 如果不提供这个参数 , wait 将会使用系统调用 , 如果系统不允许 wait3, 提供这个参数不会有任何影响 , $options 的值可以是 0 或者 WNOHANG 和 WUNTRACED 两个常数 .
函数返回退出的子进程的 PID, 或在错误时返回 -1, 或者如果提供 WNOHANG 作为 option(wait3 不可用的系统 ) 并且无有效子进程返回 0
僵尸进程 : 由于父进程在 fork 之后 , 无法预知子进程什么时候结束 , 所以子进程为了要留给父进程一些信息 , 会留下一个称作僵尸的数据结构 , 等待由父进程发起 wait 的操作来为它收尸 , 在子进程结束 ( 逻辑结束 ) 到父进程收尸前这一段时间子进程就被称为僵尸进程 , 在父进程结束后 , 所有的子进程会交由 Init 来负责 , 因此 , 如果父进程结束 , 僵尸进程都会被回收 , 但是 , 如果父进程永远不结束 , 这些僵尸进程就一直占用进程号 , 如果系统进程号耗尽 , 那么将导致无法启动新进程 , 因此 , 安全的做法是在父进程中为自己产生的子进程去收尸 .
int pcntl_waitpid(int $pid, int &$status[, int $options = 0]):
挂起当前进程直到给定 $pid 的子进程退出 , 或者当前进程接受到一个退出信号 , 或者接受到一 ige 信号去调用一个信号处理器 .
如果给定 $pid 对应的子进程在调用此函数时已经退出 ( 僵尸态 ), 函数立刻返回 , 所有的系统资源被释放 .
$pid: 进程号 , 小于 -1 表明等待的是进程组中的任何子进程 , 进程组号就是 $pid 的绝对值 . 等于 -1 表明等待任意紫禁城 , 与 pcntl_wait 函数行为一致 . 等于 0 代表等待与调用进程在同一组的子进程 , 大于 0 代表是特定的进程 .
$status: 用来由函数返回子进程状态 . 该状态信息由以下函数产生 : pcntl_wifexited, pcntl_wifstopped, pcntl_wifsignaled, pcntl_wexitstatus, pcntl_wtermsig, pcntl_wstopsig.
$options: 与 pcntl_wait 的 $options 意义相同
int pcntl_wexitstatus(int $status):
返回一个已经中断的子进程返回代码 , 此函数仅在 pcntl_wifexited 函数返回 TRUE 时有用 .
$status 参数是 pcntl_waitpid 产生的状态信息 .
bool pcntl_wifexited(int $status):
检查给定状态是否表明子进程是正常退出的 .
bool pcntl_wifsignaled(int $status):
检查给定状态是否表明子进程是由于收到某个信号退出的 .
bool pcntl_wifstopped(int $status):
检查 $status 是否能表明子进程当前已经停止 , 这个函数只有在作用于 pcntl_waitpid 函数使用的 WUNTRACED 作为 $options 参数的值时产生的 $status 上才有效 .
int pcntl_wstopsig(int $status):
通过分析 $status 返回使得子进程停止的信号的编号 , 这个函数只有在 pcntl_wifsignaled 返回 TRUE 时才有效 .
int pcntl_wtermsig(int $status):
返回使进程中断的信号编号 . 这个函数只有在 pcntl_wifsignaled 返回 TRUE 时才有效 .

PHP使用pcntl_fork实现多进程下载图片的方法
PHP+memcache实现消息队列案例分享
PhpDocumentor 2安装以及生成API文档的方法
你可能不知道PHP get_meta_tags()函数
linux使用crontab实现PHP执行计划定时任务
php中curl和file_get_content的区别
php中curl、fsocket、file_get_content三个函数的使用比较
PHP异常Parse error: syntax error, unexpected T_VAR错误解决方法
PHP FATAL ERROR: CALL TO UNDEFINED FUNCTION BCMUL()解决办法
PHP错误WARNING: SESSION_START() [FUNCTION.SESSION-START]解决方法
Fatal error: session_start(): Failed to initialize storage module: files问题解决方法
yii框架配置默认controller和action示例
php+js iframe实现上传头像界面无跳转
php中使用getimagesize获取图片、flash等文件的尺寸信息实例
PHP5.5在windows安装使用memcached服务端的方法
简单的php文件上传(实例)
8个必备的PHP功能实例代码
PHP中VC6、VC9、TS、NTS版本的区别与用法详解
zend optimizer在wamp的基础上安装图文教程
关于php程序报date()警告的处理(date_default_timezone_set)
PHP关于IE下的iframe跨域导致session丢失问题解决方法
php MessagePack介绍
PHP file_get_contents设置超时处理方法
php stream_get_meta_data返回值
PHP中time(),date(),mktime()区别介绍
php中time()和mktime()方法的区别
php读取本地文件常用函数(fopen与file_get_contents)
PHP取整函数:ceil,floor,round,intval的区别详细解析
完美解决PHP中的Cannot modify header information 问题
PHP中fwrite与file_put_contents性能测试代码
php pcntl_fork和pcntl_fork 的用法
©2014-2024 dbsqp.com