在PHP中并行/多线程执行文件

Question

我有一个cron文件cron/cron1.php。我已经为cron运行了1分钟。

因此下一个过程需要1分钟执行。

现在我想在一分钟内并行运行这个文件三次。该文件执行时间超过2分钟。

可以我运行在单个文件中该文件并行这样

file1.php

<?php 
     include("cron/cron1.php"); // run seperately 
     sleep(5); 
     include("cron/cron1.php"); // run seperately 
     sleep(5); 
     include("cron/cron1.php"); // run seperately 

?> 

在上述文件cron1.php将执行5秒差异，但高于当一个人完成了它的处理。正如我告诉过你的，每个cron1.php需要2分钟以上才能完成。所以我无法实现它。

是否有任何进程或多线程或接近，使我可以每5秒延迟运行每个cron1.php。那么我会将file1.php设置为cron作业。

Answer 1

你可以做的是在同一时间运行多个进程，像这样的东西：

exec('php cron/cron1.php > /dev/null 2>&1 &'); 
exec('php cron/cron1.php > /dev/null 2>&1 &'); 
exec('php cron/cron1.php > /dev/null 2>&1 &'); 

每个exec调用将在后台运行，所以你可以有很多需要。

Answer 2

PHP不支持多线程

http://php.net/pthreads

这里是你需要的那种逻辑的多线程例子：

<?php 
define("SECOND", 1000000); 
define("LOG", Mutex::create()); 

/* 
* Log safely to stdout 
* @param string message the format string for log 
* @param ... args  the arguments for sprintf 
* @return void 
*/ 
function slog($message, $args = []) { 
    $args = func_get_args(); 
    if ((count($args) > 0) && 
     ($message = array_shift($args))) { 
     $time = microtime(true); 
     Mutex::lock(LOG); 
     echo vsprintf( 
      "{$time}: {$message}\n", $args); 
     Mutex::unlock(LOG); 
    } 
} 

class MyTask extends Thread { 
    public $id; 
    public $done; 

    public function __construct($id) { 
     $this->id = $id; 
     $this->done = false; 
    } 

    public function run() { 
     slog("%s#%d entered ...", __CLASS__, $this->id); 
     /* don't use sleep in threads */ 
     $this->synchronized(function(){ 
      /* simulate some work */ 
      $this->wait(10 * SECOND); 
     }); 
     slog("%s#%d leaving ...", __CLASS__, $this->id); 
     $this->done = true; 
    } 
} 

$threads = []; 

function get_next_id(&$threads) { 
    foreach ($threads as $id => $thread) { 
     if ($thread->done) { 
      return $id; 
     } 
    } 
    return count($threads); 
} 

do { 
    slog("Main spawning ..."); 
    $id = get_next_id($threads); 
    $threads[$id] = new MyTask($id); 
    $threads[$id]->start(); 
    slog("Main sleeping ..."); 
    usleep(5 * SECOND); 
} while (1); 
?> 

这将产生一个新的线程每5秒钟，线程需要10秒钟才能执行。

您应该尝试找到提高单个任务速度的方法，或许通过共享一些常用的数据集。