在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秒鐘才能執行。

您應該嘗試找到提高單個任務速度的方法，或許通過共享一些常用的數據集。