Création et utilisation du multi-threading php

Cet article présente principalement la création et l'utilisation du multi-threading PHP. Les amis intéressés peuvent s'y référer. J'espère qu'il sera utile à tout le monde.

L'exemple décrit l'opération multithread implémentée par PHP à l'aide de Pthread. Partagez-le avec tout le monde pour votre référence, les détails sont les suivants :

<?php 
class vote extends Thread {
  public $res  = &#39;&#39;;
  public $url  = array();
  public $name  = &#39;&#39;;
  public $runing = false;
  public $lc   = false;
  public function __construct($name) {
    $this->res  = &#39;暂无,第一次运行.&#39;;
    $this->param  = 0;
    $this->lurl  = 0;
    $this->name  = $name;
    $this->runing = true;
    $this->lc   = false;
  }
  public function run() {
    while ($this->runing) {
      if ($this->param != 0) {
        $nt     = rand(1, 10);
        echo "线程[{$this->name}]收到任务参数::{$this->param},需要{$nt}秒处理数据.\n";
        $this->res  = rand(100, 999);
        sleep($nt);
        $this->lurl = $this->param;
        $this->param  = &#39;&#39;;
      } else {
        echo "线程[{$this->name}]等待任务..\n";
      }
      sleep(1);
    }
  }
}
//这里创建线程池.
$pool[] = new vote(&#39;a&#39;);
$pool[] = new vote(&#39;b&#39;);
$pool[] = new vote(&#39;c&#39;);
//启动所有线程,使其处于工作状态
foreach ($pool as $w) {
  $w->start();
}
//派发任务给线程
for ($i = 1; $i < 10; $i++) {
  $worker_content = rand(10, 99);
  while (true) {
    foreach ($pool as $worker) {
      //参数为空则说明线程空闲
      if ($worker->param==&#39;&#39;) {
        $worker->param = $worker_content;
        echo "[{$worker->name}]线程空闲,放入参数{$worker_content},上次参数[{$worker->lurl}]结果[{$worker->res}].\n";
        break 2;
      }
    }
    sleep(1);
  }
}
echo "所有线程派发完毕,等待执行完成.\n";
//等待所有线程运行结束
while (count($pool)) {
  //遍历检查线程组运行结束
  foreach ($pool as $key => $threads) {
    if ($worker->param==&#39;&#39;) {
      echo "[{$threads->name}]线程空闲,上次参数[{$threads->lurl}]结果[{$threads->res}].\n";
      echo "[{$threads->name}]线程运行完成,退出.\n";
      //设置结束标志
      $threads->runing = false;
      unset($pool[$key]);
    }
  }
  echo "等待中...\n";
  sleep(1);
}
echo "所有线程执行完毕.\n";

Résumé : C'est tout. Nous espérons que l'ensemble du contenu de cet article sera utile à l'étude de chacun.

Recommandations associées :

Conseils pour utiliser Enum en PHP

Comment générer des fichiers PDF en PHP

Comment résoudre les caractères chinois tronqués dans PHP MPDF

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!