multithreading - php exec() haphazardly working in pthreads -


i use loop exec() file 300 times in pthreads. full 300 exec() calls successful, times few of exec() fail , between 295 or 299 successful executes of file.

the error code exec() comes @ #127, checked file_exists on failures , says "file exists", says "file not executable" on failures. strange because executable other 295 times within loop.

my pthread version 2 months old. confident don't have pthread workers sharing files or writing same spots. scratching head else can do.

class workerthreads extends thread {     private $workerid;      public function __construct($id)     {         $this->workerid = $id;     }      public function run()     {  $mainfile="/pastlotto_1/".$this->workerid."/preset_pthread.php";          for($x=0; $x<100; $x++) {      for($o=0; $o<3; $o++)     {         $command="php $mainfile";         $finde=exec($command,$output,$return_var);          if($return_var !== 0){       echo " file not executed @ worker id ".$this->workerid."\n";     echo $return_var."\n";      if (file_exists($mainfile)) {     echo "the file $mainfile exists\n"; } else {     echo "the file $mainfile not exist\n"; }   if(is_executable($mainfile))   {   echo ("file executable\n");   } else   {   echo ("file not executable\n");   }  } else{     echo "file executed successfully"; }     } }         }//end of run  }  for($r=0; $r<1; $r++) { $workers = [];  // initialize , start threads foreach (range(0,2) $j) {      $workers[$j] = new workerthreads($j);     $workers[$j]->start();       //echo $i." worker started\n"; }  // let threads come foreach (range(0,2) $j) {     $workers[$j]->join();  } unset($workers);  } 

i able solve problem changing code fires pthreads from:

for($r=0; $r<1; $r++) { $workers = [];  // initialize , start threads foreach (range(0,2) $j) {      $workers[$j] = new workerthreads($j);     $workers[$j]->start();       //echo $i." worker started\n"; }  // let threads come foreach (range(0,2) $j) {     $workers[$j]->join();  } unset($workers);  } 

to replacement code:

$p = new pool(3);    // initialize , start threads  for($b=0; $b<3; $b++) {         $tasks[$b]= new workerthreads($b);       }     // add tasks pool queue     foreach ($tasks $task) {         $p->submit($task);     }      // shutdown wait current queue completed     $p->shutdown(); 

Comments

Popular posts from this blog

html - How to set bootstrap input responsive width? -

javascript - Highchart x and y axes data from json -

javascript - Get js console.log as python variable in QWebView pyqt -