Poszukuję rozwiązań które w skuteczny i niezbyt skomplikowany sposób pozwolą mi na zaimplementowanie w PHP wielowątkowych procesów.

Posiadam aplikację, która jest uruchamiana po stronie CLI. Jest to daemon który realizuje pewne powatarzające się zadania. W tej chwili te zadania są ustawiane w kolejkę i realizowane jedno po drugim, po zakończeniu wszystkich zadań proces rozpoczyna się od nowa. Rozwiązanie takie uzależnia sukces wszystkich zadań od każdego z nich z osobna.

Potrzebuję rozwiązania, które pozwoli mi na stworzenie procesu nadrzędnego, który będzie pilnował podprocesów a w każdym podprocesie będzie realizowane jedno zadanie i procesy będa mogły działać równolegle i niezależnie od siebie, komunikując się tylko z procesem nadrzędnym informując o swoim stanie, przebiegu zadań itp.

Rozwiązanie musi działać pod Windowsem.

Hej,
Na Windowsie nie ma możliwości używania wątków. Jak zostało napisane w dokumentacji PHP (http://www.php.net/manual/en/intro.pcntl.php):
"Note: This extension is not available on Windows platforms."

Jedynym znanym mi rozwiązaniem, realizującym taką funkcjonalność w "zbliżony" sposób, do odpalanie z głównego skryptu innego skrypu-workera, za pomocą: WScript.Shell.

[PHP] pobierz, plaintext 
while (true)
{
    if (need_to_run_new_worker)
    {
        $WshShell = new COM("WScript.Shell");
        $oExec = $WshShell->Run("\"C:\\Program Files\\Php\\php-win.exe\" worker.php parameter1 parameter2", 0, false);
    }
    sleep(1);
}
[PHP] pobierz, plaintext 

Powyższe odpali proces php-win.exe "w tle", bez dodatkowego okienka konsoli. Oczywiście warunki w jakich jest konieczność odpalania workera musisz sobie określić, żeby nie odpalał Ci się w każdym przebiegu pętli while.

mam świadomość, dlatego też szukam bibliotek zewnętrznych które moga współpracować z PHP a niekoniecznie być napisanymi w tym jezyku i załatwiać pewne kwestie związane z wątkami, rozwiązanie z procesem w tle mnie niezbyt satysfakcjonuje gdyż zależy mi na kontroli statusu procesu w procesie nadrzędnym itp.

znalazłem coś takiego jak biblioteka ZeroMQ która robi np. coś takiego:

[PHP] pobierz, plaintext 
 
<?php
/*
* Multithreaded Hello World server. Uses proceses due
* to PHP's lack of threads!
* @author Ian Barber <ian(dot)barber(at)gmail(dot)com>
*/
 
function worker_routine() {
$context = new ZMQContext();
// Socket to talk to dispatcher
$receiver = new ZMQSocket($context, ZMQ::SOCKET_REP);
$receiver->connect("ipc://workers.ipc");
 
while(true) {
$string = $receiver->recv();
printf ("Received request: [%s]%s", $string, PHP_EOL);
 
// Do some 'work'
sleep(1);
 
// Send reply back to client
$receiver->send("World");
}
}
 
// Launch pool of worker threads
for($thread_nbr = 0; $thread_nbr != 5; $thread_nbr++) {
$pid = pcntl_fork();
if($pid == 0) {
worker_routine();
exit();
}
}
 
// Prepare our context and sockets
$context = new ZMQContext();
 
// Socket to talk to clients
$clients = new ZMQSocket($context, ZMQ::SOCKET_ROUTER);
$clients->bind("tcp://*:5555");
 
// Socket to talk to workers
$workers = new ZMQSocket($context, ZMQ::SOCKET_DEALER);
$workers->bind("ipc://workers.ipc");
 
// Connect work threads to client threads via a queue
$device = new ZMQDevice($clients, $workers);
$device->run ();
 
 
[PHP] pobierz, plaintext 

source: http://zguide.zeromq.org/php:all#Multithreading-with-MQ


ale tu znowu jest używany $pid = pcntl_fork();