Параллельные вычисления, класс-обёртка для pcntl_fork()

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

(тестировалось только на линукс)

Отчего же на винде не потестили? Note: This extension is not available on Windows platforms. Документация — очень интересная штука, между прочим.

code.google.com/p/scalr/source/browse/scalr-2/trunk/app/cron-ng/jobs/Poller.php

Посмотрите как работают наши кронджобы. Мы используем Semaphore Functions: очереди, семафоры и шаред мемори. Все настраивается, можно к примеру запустить пулл процессов и он будет висеть и обрабатывать задачи как толкьо они будут появлятся в очереди. Можно просто переодически запускать крон, он стартует воркеры, делает работу и прибивается. И много других вкусных плюшек.

У меня есть некоторые наработки в эту сторону github.com/kulikov/php-threads-manager

там мультипроцессорность реализуется тремя способами (на выбор):
1. через запуск отделных процессов через popen()
2. через tcp сокеты stream_socket_client()
3. через pcntl_fork() // не доделано

В основном я пользовался popen как самым надежным и прозрачным способом. сокеты использовлись коллегами для дебага под виндой. а форки так и не доделал.
Самый главный вопрос: как наиболее оптимально организовать обмен данными между родителем и потомком. По завершению работы в потомке складывать ответ во временный файл, а родитель из него потом все считывает? Пожалуй надо так и сделать. :)

Всё это проходил и из опыта вот что могу сказать:
Если подключить PECL-расширение proctitle (расширение бета, по причине отсутствия тестов, но работает исправно, проверено) то воркеры смогут задавать свои заголовки в ps или top, например. Это полезно что бы знать кто какие роли выполняет и чем занят.
Fork работает по принципу copy-on-write поэтому самое тяжелое лучше выгрузить в память сразу.
Некоторые расширения ведут себя не корректно после fork-а. Так, например, mysqli разрывает соединение не только в чаилдах, но и в родителе.
Комуникацию по коммандам удобно длеать через сигналы через расширение POSIX. Для более сложной комуникации лучше использовать pair сокеты. По pair советам можно отдавать результат из воркера в мастер по завершению воркера (как-то проще чем через семафоры/мутексы). При включении в дело libevent можно получить очень функциональный событийный демон.
Не забывайте делать setsid (posix_setsid).

писали игровых демонов на php. pcntl+libevent. демон висел на порту и слушал и обрабатывал HTTP запросы. был некой прослойкой между фронтом и БД. запускалось форками. управление через SIGNAL. Libevent позволял создавать таймеры и прочую вкусноту. в процессе разработки были исправлены баги в php_libevent с Тони.

Понравилось :)

case SIGTERM:
    echo 'opa!';
    return;

Автор забыл указать
что это возможно только в бэдграундовских процессах

Приветствую всех)

При всех моих тёплых чувствах к PHP, он, как мне кажется, не лучший инструмент для реализации многопоточности и мультипроцессности…

Кроме того, как тут уже говорили, при создании многопоточного приложения всегда следует контролировать доступ к общим ресурсам… Для примера в методе log (к которому насколько я понимаю обращаются «рабочие») следовало воспользоваться хотя бы функцией file_put_contents с флагами FILE_APPEND и LOCK_EX.

Ещё бросилось в глаза в методе getFormattedMessage почему-то автор предпочитает вызвать 4 раза функцию str_replace:
$message_formatted = str_replace('%time', $time, self::OUTPUT_FORMAT );
$message_formatted = str_replace('%role', $role, $message_formatted);
$message_formatted = str_replace('%pid', $this->pid, $message_formatted);
$message_formatted = str_replace('%message', $message, $message_formatted);
но ведь можно было использовать массивы в качестве параметров $search и $replace… хотя тут вообще уместна другая функция — sprintf (или её аналог vsprintf)…

Код просматривал мельком, поэтому сказал о том, что бросилось в глаза (getFormattedMessage рядом с методом log =) ).

Многопоточность и мультипроцессность — эта та область где даже «гуру» совершают ошибки… возможно стоит получше изучить сам php, прежде чем хвататься за многопоточность. А если уж берёшься за неё, то лучше хорошенько разобраться во всех механизмах прежде, чем писать на хабр.

Может быть удобнее будет запускать процесс с помощью system(«php /path/script.php»);?
Честно говоря, не проверял этот метод, но управляю демонами через PHP

#!/usr/bin/php
<?php
echo "________________________________________\n";
$command = "restart";
if (isset($argv[1]))
    $command = trim($argv[1]);
echo "Начинаем сканировать процессы...\n";
exec("ps -A -F | grep php", $output);
$folder = dirname(__FILE__);
$php = "php";
$names = array(
    "system",
    "inspector",
    "drivers",
    "android",
);
echo "Определяем демоны multitaxi...\n";
foreach ($output as $out) {
    if (preg_match_all("#.*php ".$folder."/(.*)\.php#isU", $out, $matches)) {
        $matches[0][0] = str_replace("  ", " ", $matches[0][0]);
        $matches[0][0] = str_replace("  ", " ", $matches[0][0]);
        $matches[0][0] = str_replace("  ", " ", $matches[0][0]);
        $matches[0][0] = str_replace("  ", " ", $matches[0][0]);
        $matches[0][0] = str_replace("  ", " ", $matches[0][0]);
        $daemon = $matches[1][0];
        $matches = explode(" ", $matches[0][0]);
        $pid = $matches[1];
        //echo $daemon;
        if (in_array($daemon, $names)) {
            if ($command != "view")
                exec("kill -9 ".$pid);
            echo "Процесс: ".$daemon." (".$pid.")\n";
        }
    }
}
if ($command != "stop" && $command != "view") {
    echo "Запускаем процессы...\n";
    foreach ($names as $d) {
        exec($php." ".$folder."/".$d.".php 1>> /dev/null 2>> /dev/null &");
        echo $php." ".$folder."/".$d.".php 1>> /dev/null 2>> /dev/null & \n";
    }
}
echo "Готово!\n";
echo "________________________________________\n";

?>

Да, есть еще замечательная штука gaerman. Можно запустить кучу одинаковых процессов, а с помощью gaerman посылать задачи и ловить ответы.