Эмуляция многопоточности в PHP

Идея интересная, но я бы её описал словами, что бы можно было оценить, нечитая код. Выступая в качестве капитана очевидности, разъясняю: автор использовал многопоточность вебсервера и неблокирующие операции для работы с сокетами.

Я PHP не знаю, разве нельзя было бы достигнуть того же эффекта, используя что-то типа exec для запуска php скрипта как процесса OS и неблокирующие операции для работы с ним?

По теме: Разработка многозадачных приложений на PHP V5

В данном случае через HTTP жутко глупая идея, т.к.
1). Займёт WEB сервер работой, что плохо. Может получиться ситуация, когда пользователи будут ждать, пока их запрос обработается WEB сервером.
2). Время коннекта по HTTP даже локально довольно большое. В крайнем случае лучше уж Unix socket или pipes.

Делать такие вещи нужно скриптами, работающими в командной строке. Т.к.
1). Можно установить приоритет исполнения (proc_open)
2). Не ограничены ресурсы и время исполнения (злоупотреблять конечно этим не нужно).

Я думаю вам стоит изучить вот этот раздел мануала: lv.php.net/manual/ru/refs.fileprocess.process.php

Суть многопоточности в shared state, что на php реализовать невозможно, да и не потоки это, а отдельные системные процессы. В общем, надо не страдать фигнёй, а взять нормальный тул с поддержкой многопоточности типа Java, если это действительно так надо.

Слишком громкий заголовок, но, увы, выбрана не слишком подходящая терминология.

Собственно это вряд ли эмуляция и PHP здесь совсем не причём. Подобные запросы к серверу выполняющему задачи параллельно можно генерировать любым удобным способом (то есть PHP можно смело удалить из заголовка). Затем, многопоточность — это несколько иное понятие, относящееся к множеству «потоков исполнения» в контексте одного процесса (характерный признак — разделяемые ресурсы, доступные потокам в рамках процесса).

Можно было использовать асинхронные (неблокирующие) сокеты PHP (реализовав протокол SMTP средствами PHP), это можно было бы назвать «эмуляцией» многопоточности (понадобился бы «планировщик» обслуживающий события на сокетах).

Статья скорее об организации многозадачности посредством подходящего web-сервера, нежли о многопоточности в PHP. Да собственно, можно было воспользоваться средствами ОС используя какое-нибудь приложение для отправки почти (например запуская через exec() программу sendmail), что уменьшило бы накладные расходы.

1. Как будет вести себя система, если основной скрипт прервет работу, обработав лишь половину данных?

2. Веб сервер может не взять запрос на обслуживание, если перегружен. Тогда что, получится, что скрипт не выполнит обработку всех данных?

3. Что будет, если основной скрипт будет запущен не один раз, а нечаянно несколько раз подряд?

4. Не кажется ли Вам, что, если нужно обработать большой объем данных (скажем, в Вашем примере, отправив десяток тысяч E-mails), основной скрипт, который использует Ваш класс, может умереть например по таймауту?

В общем можно еще долго рассказывать… но в двух словах — пожалуйста, никогда-никогда не делайте так.

Как так нет многопоточности? Есть форки.

Давайте я тоже поделюсь своими мыслями о том, как делался многопоточность на PHP.

1. Ну, во-первых в PHP есть специальный (правда, не совсем надежный) механизм для этого: называется Process Control, который работает только на основе никсов. ru2.php.net/manual/ru/book.pcntl.php
Я редко видел, чтоб подобное использовалось, вероятно потому что данное решение просто невозможно нормально отлаживать (я пытался, ага).

2. С помощью запусков php-скриптов из php командами System program execution — ru2.php.net/manual/ru/book.exec.php. Суть такая запускаем фоновое выполнение скрипта и работаем дальше, а он там в фоне вытворяет уже сто-то своё. Единственное — такими скриптами сложно управлять. Для этого я делал так — создавал таблицу, и каждый новый запущеный скрипт вносил в неё новую строчку. Автоинкремент получался уникальным идентификатором процесса. Скрипт крутился в бесконечном цикле и опрашивал таблицу на предмет существования своей строчки, и если её не находил — то завершался. Ну, или просто — выполнял то, что нужно и опять же — завершался. Кстати, на такой подход замечательно смтрится для рассылки — мы добавляем адреса в некую базу, а скрипт висит себе запущеным, извлекает из неё записи и рассылает по ним. Да, не все сразу. За то надежно. :-) Я сделал вывод — самый надежный способ.

3. Использование http. Это очень спорно, лучше этого не делать — потому что ответа все равно придется ждать. И хоть используй curl_multi_exec, хоть еще что-то — не. Это и сервер вводин в нагрузку и вообще как-то… Кстати, чтоб обойти это ожидание я пытался сделать следующее «гениальное» решение. Открывал поток к скрипту он какбэ начинал выполнятся, а я раз — и тупо закрывал соединение. Один раз это сработает нормально. Даже два. До тех пор, пока на сервер на ляжет нагрузка, тогда апач начнет рубить такие безисходные процессы. Вобщем, не работает это. И вообще хак. :-))

4. Да, еще можно сделать подобие daemon-а на php — язык это позволяет. Это понадежнее и устойчевее, чем HTTP, но сложнее.

Самый надежный способ все же — это нормально организованный механизм запуска фонового скрипта. С вычислением и присвоением ID, проверкой мертвых и зависших скриптов, обмена через базу, Memcached или семафоры.

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

ua.php.net/manual/ru/function.pcntl-fork.php

имхо удобнее

а вообще многопоточные приложения пишу либо на пайтоне либо на перле — мне кажется там удобнее

Простите, но зачем такой изврат, если есть pcntl? Хотите — напишу руководство, как раз сейчас занимаюсь многопотоковым приложением.

Ну после фразы

нескольких (однотипных) потоков, выполняющихся «параллельно», то есть без упорядочивания по времени — выполнился один, пошел следующий.

уже не хочется читать про очередную «многопоточность в пхп»…

1. используйте raw sockets
2. обрабатывайте коды состояний/ответов желательно по всем платформам.
3. поправте работу с таймаутами
4. отдельными процессами запускайте многопоточное получение ип адресов удаленных хостов

«Суть многопоточности (для приложения) состоит в том, что процесс может состоять из нескольких (однотипных) потоков, выполняющихся «параллельно», то есть без упорядочивания по времени — выполнился один, пошел следующий...»

Вообще-то, многопоточность — это когда два потока работабт ОДНОВРЕМЕННО в пределах одной программы, а не по порядку.

Подскажите пожалуйста у всех ли нормально работает? У меня в PHP 5.2.2 установка stream_set_blocking($fsock, 0);
дает ошибки fwrite(): send of 256 bytes failed with errno=11
В чем может быть дело?

Подскажите пожалуйста у всех ли нормально работает? У меня в PHP 5.2.2 установка stream_set_blocking($fsock, 0);
дает ошибки fwrite(): send of 256 bytes failed with errno=11
В чем может быть дело?

Интересно появится ли когда нибудь в PHP многопоточность. В 6й версии тоже вроде не планируется, хотя довольно актуальная тема вроде. Но чисто теоретически можно реализовать многопоточность через рассширение на си.

Мне кажется, что многопоточность в PHP — это такой Святой Грааль, Секрет Бессмертия и Вечный Двигатель в одном флаконе.

Я конечно понимаю что это некропостинг, но нельзя ли обновить ссылку, а то она побилась.

Pardon moi за некропостинг, но ссылка бятая =/

В дополнение к материалу могу сказать, что при доработке класса можно будет выполнять одновременно разнотипные задачи на разных серверах и с разными протоколами. Опробовано — работает =)