php pthreads 多線程擴展的使用：一個較爲穩定例子。

時間 2019-11-12

標籤 php pthreads 多線程擴展使用一個較爲穩定例子欄目 PHP 简体版

原文原文鏈接

今天研究了worker stackable的配合方法，寫了兩種形式，雖然能工做，可是都會出現內存不聽增加的問題； php

因而把第一個方法的代碼郵件給了做者，到如今他沒有回覆我。 this

我最後放棄二者配合的方式，直接使用worker，發現到如今執行了582000個工做，內存沒有增加，速度也基本穩定，代碼以下： spa

[php] view plain copy print ?

<?php
ini_set('zend.enable_gc', true);
class ExampleWorker extends Worker {
public $stack_count = 0;
public function __construct() {}
public function run(){
sleep(1);//waiting for data
$count = 0;
$data_flag = true;
$stime = microtime(true);
while(1){
if($data = $this->shift()){
$data_flag = true;
$this->doSomeWork();
if((++$count)%1000==0){
printf("Work Mermory used %.3fMB RAM, time: %3f===> %d \n",
memory_get_peak_usage(true)/1048576, (microtime(true) - $stime), $count);
$stime = microtime(true);
}
}else{
usleep(100000);
}
}
exit;
}
private function doSomeWork(){
$str = 'sdalsadkfkasd;lfksa;ldfkas;lkf;lsadkf;as';
$len = strlen($str);
$s = substr($str,rand(0,$len));
$len = floor(strlen($s)/2);
for($i=0;$i<$len;$i++){
$tmp = $s[$i];
$idx = intval($len-$i-1);
$s[$i] = $s[$idx];
$s[$idx] = $tmp;
}
}
}
$worker= new ExampleWorker(sprintf("Worker [%d]", 0));
$worker->start();
$stime = microtime(true);
$count = 3000000;//99999999;
$total = $count*5;
$ct = 0;
while($count--){
//for ($target = 0; $target < 5; $target++)
$worker[]='data_'.(++$ct);
usleep(rand(200,1800));
}
//sleep(10);
$runtime = (microtime(true)-$stime);
printf("---------------------------------------------------------\n");
printf("Used time is %f \n", $runtime);
printf("Mermory used %.3fMB RAM, added %d, left %d\n", memory_get_peak_usage(true)/1048576, $total, count($worker));
printf("---------------------------------------------------------\n");
//var_dump($works);