How does PHP obtain the job queue, create an execution process, and wait for the end_PHP tutorial

How PHP obtains the job queue, creates the execution process, and waits for the end

A background job management instance, the process is: obtain the job queue from the database, create a new process for execution , Wait for the job to end.

Code snippet:

class Controller_Jobs extends Controller_Base{

public function before(){

parent::before();

　if(Request::$protocol != "cli"){

die("Only cli allowed!n");

　}

　}

public function after(){

parent::after();

//do some cleaning tasks

　}

private function _execJobCommand($joburi,$paras){

$php_exec = Kohana::config("picsou.php_exec");

　$php_index = APPINDEX;

　$command_args = array();

$command_args[] = $php_index;

$command_args[] = "--uri=".$joburi;

foreach ($paras as $para => $value){

　$command_args[] = "--".$para."=".$value;

　}

//var_dump($command_args);exit;

echo "exec command:".$php_exec."n";

pcntl_exec($php_exec,$command_args);

　}

　/*

* Running jobs in queues

　*/

Public function action_run(){

　$requestCount = 0;

while(true){

　$sql = "select * from job_queue where status='1' and approved='1' order by id";

$jobs = DB::query(Database::SELECT,$sql)->execute()->as_array();

　if($jobs){

foreach ($jobs as $job){

$requestCount ++;

　//update the jobs status as running

DB::update('job_queue')->set(array('status'=>'2'))

　->where('id','=',$job['id'])->execute();

　$job_pid = pcntl_fork();

　if($job_pid == -1){

die("Could not fork Child");

　} else if($job_pid == 0 ){

$this->_execJobCommand($job['job_uri'],json_decode($job['paras'],true));

echo "finish Childn";

exit(0);

　//run jobs here

　} else{

echo "Waiting for jobn";

ob_flush();

　$child_pid = pcntl_waitpid($job_pid,$status, WUNTRACED);

echo "waitpid end:".$status."n";

　if($status == 0){

　//job completed

DB::update('job_queue')->set(array('status'=>'999'))

　->where('id','=',$job['id'])->execute();

echo "Child Finishedn";

ob_flush();

　}else{

DB::update('job_queue')->set(array('status'=>'-1'))

　->where('id','=',$job['id'])->execute();

echo "Child Failedn";

ob_flush();

　}

　}

　}

　}

else{

　if($requestCount >=10){

echo "Have a rest, I have processed 10 jobsn";

exit;

　}

　//no job to run

　//echo "No jobn";

ob_flush();

sleep(5);

　}

　}

　}

　}

http://www.bkjia.com/PHPjc/848339.htmlwww.bkjia.comtruehttp: //www.bkjia.com/PHPjc/848339.htmlTechArticleHow PHP obtains the job queue, creates an execution process, and waits for the end of a background Job management instance. The process is: from the database Obtain the job queue, create a new process for execution, and wait...