Task ID: 1 Task ID: 0 Task ID: 2 Task ID: 3 Task ID: 4 Task ID: 5 Task ID: 6 Task ID: 7 Task ID: 8 Task ID: 9 Total time: 10 sВидно, что скрипт выполнялся всего 10 секунд.
воскресенье, 8 апреля 2012 г.
PHP. Многозадачность aka многопоточность.
Полноценных потоков(Threads), как в java, perl или python, в php нет. Но во многих случаях они и не нужны. Класс Pool создает новые процессы ос, запуская php скрипты и передавая им параметры командной строки. Взаимодействие между процессами можно реализовать различными способами, например, разделяемая память и семафоры, базы данных (sqlite в оперативной памяти), apc, memcache, файлы. Придется, разумеется, реализовать блокировки при записи из различных процессов, так как, например, apc и memcache их не имеют.
Запускаем и смотрим:
Подписаться на:
Комментарии к сообщению (Atom)
Большое спасибо за код. Пригодился в одно проекте.
ОтветитьУдалитьСкажите пожалуйста, являются ли эти строки обязательными
while(false !== ($output = $mtasking->iterate()))
if($output)
echo $output;
А именно вызов функции $mtasking->iterate()? Можно его удалить?
У меня запускается много процессов, больше 200, И после того как все процессы выполнятся, получаю ошибку:
Warning: stream_select() [function.stream-select]: unable to select [2]: No such file or directory (max_fd=1580) in Multitasking.php on line 34
Если в общей сумме запускается не больше 100 процессов, то тогда ошибки нет.
а вообще лучше изучите вот это
Удалитьhttps://en.wikipedia.org/wiki/Java_concurrency
обязательно, именно он запускает процесс порождения процессов,
ОтветитьУдалитьа сколько задач вы создаете в цикле, второй операнд отвечает за их кол-во
while($n < 10) ...
?
Разве? Как я понял функция iterate(), отслеживает уже запущенные процессы на предмет появления символов, доступных для чтения, выводит их, и если процессы закончили свою задачу то закрывает их.
УдалитьА запускает новые процессы функция addTask(), так как именно в ней происходит вызов функции proc_open(). Или я не прав?
Ошибка появляется если while($n < 64) и более, то есть при while($n < 63) ошибки нет. Много гуглил, но так ничего толкового не нашел. Сложилось впечатление что функция stream_select() попросту не способна отслеживать потоки, перечисленные в массиве "read", если их больше 63.
Вы совершенно правы. Возможно проблема в реализации stream_select или это может зависеть от системы. В любом случае я бы посмотрел в сторону полноценной реализации многопоточности например в Java. Это не более чем костыль. Нет ни Concurrent Colletions, CycleBarrier и тд. Проблема во взаимодействии между потоками ...
УдалитьПрочитал описание функции stream_select(), в принципе понимаю что она делает. Но не могу понять что она делает конкретно в этом коде, для чего она нужна?
ОтветитьУдалить