PHP скрипт синхронизации - PullRequest
Новая
       8

PHP скрипт синхронизации

2 голосов
/ 09 апреля 2011

Мне нужно запустить некоторый php-скрипт в фоновом режиме (без ожидания), а затем дождаться завершения всех процессов, что-то (если вы знакомы с многопоточностью), похожее на барьер.

Пример: 

//...code...

run_script('myscript1.php');//it's like an exec but doesen't wait for the script to finish
run_script('myscript2.php');//it's like an exec but doesen't wait for the script to finish
run_script('myscript3.php');//it's like an exec but doesen't wait for the script to finish

do_something();

wait_until_all_proc_are_finished();//it will wait until all script are executed
do_something_else();
//....

Я создал скрипт, который должен справиться с задачей, я проверил его в консоли, и он хорошо работает, но он не работает на страницах php, я не понимаю почему! 

class TSync{
    private $threads=array();
    function tcreate($p){
            $tname=tempnam(null,'THS_');//create a temp name               

            $p=addslashes($p);//just to be sure

            $name=addslashes($tname);

            $ex= 'php -r "$fp=fopen(\''.$name.'\',\'r+\');flock($fp,LOCK_EX);include(\''.$p.'\');fclose($fp);"';

            run_on_background($ex);//execute it on background      

            $this->threads[count($this->threads)]=$tname;

            return count($this->threads)-1;//returns the thread "id"

    }
    function twait($id){
        $f=$this->threads[$id];//recover the name
        /***even this doesen't work***
        $fp=fopen($f,'r');
        flock($fp,LOCK_EX);
        fclose($fp);   
        */
        echo date("H:i:s"),"#Locking on $f<br/>";

        $ex= 'php -r "$fp=fopen(\''.$f.'\',\'r\');flock($fp,LOCK_EX);fclose($fp);"';

        exec($ex);
        unlink($f);

    }


}

$t=new TSync();//create the class

$f=$t->tcreate(dirname(__FILE__).'/testth.php');//this is a test script that waits 10s
$t->twait($f);//now you should wait the script,commenting this line should result on the script not waiting

Пример эффективного кода, запущенного на консоли (проверено на windows) 

start /b php.exe -r "$fp=fopen('C:\\Windows\\Temp\\THS6D7.tmp','w');flock($fp,LOCK_EX);include('C:/.../testth.php');fclose($fp);"

Если я запускаю код несколько раз, второй скрипт будет ждать первого, поэтому он должен работать.

1 Ответ

0 голосов
/ 20 апреля 2011

Вы должны быть в состоянии решить эту проблему с помощью Gearman

...