PHP基于进程控制函数实现多线程

php有一组进程控制函数(编译时需要–enable-pcntl与posix扩展),使得php能在nginx系统中实现跟c一样的创建子进程、使用exec函数执行程序、处理信号等功能。

CentOS 6 下yum安装php的,默认是不安装pcntl的,因此需要单独编译安装,首先下载对应版本的php,解压后

cd php-version/ext/pcntl
phpize
./configure && make && make install
cp /usr/lib/php/modules/pcntl.so /usr/lib64/php/modules/pcntl.so
echo "extension=pcntl.so" >> /etc/php.ini
/etc/init.d/httpd restart 

方便极了。

下面是示例代码:

<?php
header('content-type:text/html;charset=utf-8' ); 

// 必须加载扩展
if (!function_exists("pcntl_fork")) {
  die("pcntl extention is must !");
}
//总进程的数量
$totals = 3;
// 执行的脚本数量
$cmdArr = array();
// 执行的脚本数量的数组
for ($i = 0; $i < $totals; $i++) {
  $cmdArr[] = array("path" => __DIR__ . "/run.php", 'pid' =>$i ,'total' =>$totals);
} 

/*
展开:$cmdArr
Array
(
  [0] => Array
    (
      [path] => /var/www/html/company/pcntl/run.php
      [pid] => 0
      [total] => 3
    ) 

  [1] => Array
    (
      [path] => /var/www/html/company/pcntl/run.php
      [pid] => 1
      [total] => 3
    ) 

  [2] => Array
    (
      [path] => /var/www/html/company/pcntl/run.php
      [pid] => 2
      [total] => 3
    ) 

)
*/ 

pcntl_signal(SIGCHLD, SIG_IGN); //如果父进程不关心子进程什么时候结束,子进程结束后,内核会回收。
foreach ($cmdArr as  $cmd) {
  $pid = pcntl_fork();  //创建子进程
  //父进程和子进程都会执行下面代码
  if ($pid == -1) {
    //错误处理:创建子进程失败时返回-1.
    die('could not fork');
  } else if ($pid) {
    //父进程会得到子进程号,所以这里是父进程执行的逻辑
    //如果不需要阻塞进程,而又想得到子进程的退出状态,则可以注释掉pcntl_wait($status)语句,或写成:
    pcntl_wait($status,WNOHANG); //等待子进程中断,防止子进程成为僵尸进程。
  } else {
    //子进程得到的$pid为0, 所以这里是子进程执行的逻辑。
    $path  = $cmd["path"];
    $pid = $cmd['pid'] ;
    $total = $cmd['total'] ;
    echo exec("/usr/bin/php {$path} {$pid} {$total}")."\n";
    exit(0) ;
  }
}
?> 

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持我们。

(0)

相关推荐

  • PHP实现数组的笛卡尔积运算示例

    本文实例讲述了PHP实现数组的笛卡尔积运算.分享给大家供大家参考,具体如下: 数组的笛卡尔积在实际中还是挺有用处的,比如计算商品的规格时就经常用到,下面写一种实现方式,如下代码 $arr = array( array(2), array(6,7), array('a','b','c') ); function dikaer($arr){ $arr1 = array(); $result = array_shift($arr); while($arr2 = array_shift($arr)){

  • PHP笛卡尔积实现原理及代码实例

    笛卡尔积是指在数学中,两个集合X和Y的笛卡尔积(Cartesian product),又称直积,表示为X*Y,第一个对象是X的成员而第二个对象是Y的所有可能有序对的其中一个成员. 假设集合A={a,b},集合B={0,1,2},则两个集合的笛卡尔积为{(a,0),(a,1),(a,2),(b,0),(b,1),(b,2)} 实现思路 先计算第一个集合和第二个集合的笛卡尔积,把结果保存为一个新集合. 然后再用新集合与下一个集合计算笛卡尔积,依此循环直到与最后一个集合计算笛卡尔积. 例如有以下几个集

  • thinkphp诸多限制条件下如何getshell详解

    前言 先说说2020_n1CTF的web题Easy_tp5复现问题. 这个题在保留thinkphp的RCE点的同时,并且RCE中ban掉许多危险函数,只能允许单参数的函数执行.对于现在在网络中流传的文件包含的点也增加了限制. smile yyds! 先说一下这个题限制条件: thinkphp版本:5.0.0 php版本:7 对于包含文件增加了限制 ban掉所有的单参数危险函数 设置open_basedir为web目录 设置仅在public目录下可写 在TP5.0.0的中,目前公布的只是存在利用R

  • PHP笛卡尔积实现算法示例

    本文实例讲述了PHP笛卡尔积实现算法.分享给大家供大家参考,具体如下: <?php $arr = array(array(1,3,4,5),array(3,5,7,9),array(76,6,1,0)); /** ** 实现二维数组的笛卡尔积组合 ** $arr 要进行笛卡尔积的二维数组 ** $str 最终实现的笛卡尔积组合,可不写 ** @return array **/ function cartesian($arr,$str = array()){ //去除第一个元素 $first =

  • PHP基于自定义函数生成笛卡尔积的方法示例

    本文实例讲述了PHP基于自定义函数生成笛卡尔积的方法.分享给大家供大家参考,具体如下: <?php $color = array('red', 'green'); $size = array(39, 40, 41); $local = array('beijing', 'shanghai'); echo "<pre>"; print_r(combineDika($color, $size, $local)); /** * 所有数组的笛卡尔积 * * @param un

  • PHP如何防止用户重复提交表单

    我们提交表单的时候,不能忽视的一个限制是防止用户重复提交表单,因为有可能用户连续点击了提交按钮或者是攻击者恶意提交数据,那么我们在提交数据后的处理如修改或添加数据到数据库时就会惹上麻烦. 那么如何规避这中重复提交表单的现象出现呢?我们可以从很多方面入手: 首先从前端做限制.前端JavaScript在按钮被点击一次后禁用,即disabled,这个方法简单的防止了多次点击提交按钮,但是缺点是如果用户禁用了javascript脚本则失效. 第二,我们可以在提交后做redirect页面重定向,即提交后跳

  • Nginx+php配置文件及原理解析

    采用nginx+PHP作为webserver的架构模式,在现如今运用相当广泛.然而第一步需要实现的是如何让nginx正确的调用php.由于nginx调用php并不是如同调用一个静态文件那么直接简单,是需要动态执行php脚本.所以涉及到了对nginx.conf文件的配置.这一步对新手而言一般需要网上查资料,对于一般的熟手而言,也有不少同学并没有搞透彻为何要如此这般配置.本文的主要内容为如何在nginx server中正确配置php调用方法,以及配置的基本原理. 一.nginx+php运行原理: 首

  • php计算多个集合的笛卡尔积实例详解

    笛卡尔积 笛卡尔积是指在数学中,两个集合X和Y的笛卡尔积(Cartesian product),又称直积,表示为X*Y,第一个对象是X的成员而第二个对象是Y的所有可能有序对的其中一个成员. 假设集合A={a,b},集合B={0,1,2},则两个集合的笛卡尔积为{(a,0),(a,1),(a,2),(b,0),(b,1),(b,2)} 实现思路 先计算第一个集合和第二个集合的笛卡尔积,把结果保存为一个新集合. 然后再用新集合与下一个集合计算笛卡尔积,依此循环直到与最后一个集合计算笛卡尔积. 例如有

  • PHP实现笛卡尔积算法的实例讲解

    概念 在数学中,两个集合X和Y的笛卡儿积(Cartesian product),又称直积,表示为 X × Y.设A.B是任意两个集合,在集合A中任意取一个元素x,在集合B中任意取一个元素y,组成一个有序对(x,y),把这样的有序对作为新的元素,他们的全体组成的集合称为集合A和集合B的直积,记为A×B,即 A×B={(x,y)|x∈A且y∈B}. 假设集合 A={a, b},集合 B={0, 1, 2},则两个集合的笛卡尔积为 {(a, 0), (a, 1), (a, 2), (b, 0), (b

  • PHP基于进程控制函数实现多线程

    php有一组进程控制函数(编译时需要–enable-pcntl与posix扩展),使得php能在nginx系统中实现跟c一样的创建子进程.使用exec函数执行程序.处理信号等功能. CentOS 6 下yum安装php的,默认是不安装pcntl的,因此需要单独编译安装,首先下载对应版本的php,解压后 cd php-version/ext/pcntl phpize ./configure && make && make install cp /usr/lib/php/mod

  • python基于concurrent模块实现多线程

    引言 之前也写过多线程的博客,用的是 threading ,今天来讲下 python 的另外一个自带库 concurrent .concurrent 是在 Python3.2 中引入的,只用几行代码就可以编写出线程池/进程池,并且计算型任务效率和 mutiprocessing.pool 提供的 poll 和 ThreadPoll 相比不分伯仲,而且在 IO 型任务由于引入了 Future 的概念效率要高数倍.而 threading 的话还要自己维护相关的队列防止死锁,代码的可读性也会下降,相反

  • 基于进程内通讯的python聊天室实现方法

    本文实例讲述了基于进程内通讯的python聊天室实现方法.分享给大家供大家参考.具体如下: #!/usr/bin/env python # Added by <ctang@redhat.com> import sys import os from multiprocessing import connection ADDR = ('', 9997) AUTH_KEY = '12345' class Server(object): def __init__(self, username): se

  • Windows下使用Dev-C++开发基于pthread.h的多线程程序实例

    一.下载Windows版本的pthread 目前最新版本是:pthreads-w32-2-9-1-release.zip. 二.解压pthread到指定目录 我选择的目录是:E:\DEV-CPP\Pthread 完成后,该目录会多出三个文件夹:Pre-built.2,pthreads.2,QueueUserAPCEx. 三.配置Dev-C++编译选项 1)点击"工具"→"编译选项"→"目录"→"c++包含文件",浏览到刚才解压

  • winform基于异步委托实现多线程摇奖器

    本文实例讲述了winform基于异步委托实现多线程摇奖器.分享给大家供大家参考.具体实现方法如下: 复制代码 代码如下: using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Linq; using System.Text; using System.Threading; using Sys

  • 基于Java回顾之多线程详解

    线程是操作系统运行的基本单位,它被封装在进程中,一个进程可以包含多个线程.即使我们不手动创造线程,进程也会有一个默认的线程在运行. 对于JVM来说,当我们编写一个单线程的程序去运行时,JVM中也是有至少两个线程在运行,一个是我们创建的程序,一个是垃圾回收. 线程基本信息 我们可以通过Thread.currentThread()方法获取当前线程的一些信息,并对其进行修改. 我们来看以下代码: 复制代码 代码如下: 查看并修改当前线程的属性 String name = Thread.currentT

  • 基于Java回顾之多线程同步的使用详解

    首先阐述什么是同步,不同步有什么问题,然后讨论可以采取哪些措施控制同步,接下来我们会仿照回顾网络通信时那样,构建一个服务器端的"线程池",JDK为我们提供了一个很大的concurrent工具包,最后我们会对里面的内容进行探索. 为什么要线程同步? 说到线程同步,大部分情况下, 我们是在针对"单对象多线程"的情况进行讨论,一般会将其分成两部分,一部分是关于"共享变量",一部分关于"执行步骤". 共享变量 当我们在线程对象(Run

  • 基于一个应用程序多线程误用的分析详解

    一.需求和初步实现很简单的一个windows服务:客户端连接邮件服务器,下载邮件(含附件)并保存为.eml格式,保存成功后删除服务器上的邮件.实现的伪代码大致如下: 复制代码 代码如下: public void Process()        {            var recordCount = 1000;//每次取出邮件记录数            while (true)            {                using (var client = new Pop

  • Python基于进程池实现多进程过程解析

    1.注意:pool必须在 if __name__ == '__main__' 下面运行,不然会报错 2.多进程内出现错误会直接跳过该进程,并且默认不会打印错误信息 3.if__name__下面的数据需要通过参数传入主函数里面,不然主函数获取不到该数据值而报错. 4.若不通过传参形式传入数据,可以定义全局变量.但是全局变量的值不能在多进程里面进行修改. 代码如下 from multiprocessing import Pool # 进程池,用于多进程 import os # 用于获取当前执行的文件

  • 基于PHP pthreads实现多线程代码实例

    在某些情况,我们要使用 PHP 进行重复的任务,但是只能完成单次,叠加起来的话执行时间会非常长,所以就要将任务分配到多个线程来分别执行. 但 PHP 在默认情况下是没有多线程的,必须要使用 pthreads PHP 扩展,这个扩展能真正的支持和实现多线程.多线程在处理重复性的循环任务,能够大大缩短程序执行时间. 要使用这个扩展,就必须使用线程安全的版本. 在编译 PHP 的时候, –enable-maintainer-zts ​这个选项是必须的,其他的根据自己的需求来添加 <?php error

随机推荐