PHP.SU

Программирование на PHP, MySQL и другие веб-технологии

PHP.SU Портал

Главная

Помощь

Поиск

Поиск Яндекс Вакансии

Пользователи

Здравствуйте, Гость

( Вход · Регистрация · Правила форума )

Забыли пароль?

Таймаут потока PThreads, как реализовать?

Форумы портала PHP.SU » PHP » Программирование на PHP (Модераторы: valenok, OrmaJever, Саныч)

Страниц (1): [1]

Без описания

Поиск в теме | Версия для печати

freelsd	Отправлено: 11 Апреля, 2015 - 15:27:21
Гость Покинул форум Сообщений всего: 108 Дата рег-ции: Февр. 2015 Помог: 1 раз(а)	У меня есть такой код: PHP: скопировать код в буфер обмена <?PHP /** * Author: Abu Ashraf Masnun * URL: http://masnun.me / //define("TMT",3); class WorkerThreads extends Thread { private $workerId; public function __construct($string) { $this->command_string = trim($string); } public function run() { echo $this->command_string." ".Thread::getCurrentThreadId()."\n"; //sleep(rand(0, 3)); $str = "C:\\Users\\Alex\\Desktop\\2web\\phantom\\phantomjs.exe C:\\Users\\Alex\\Desktop\\2web\\test.js "; $url = $this->command_string; $d = explode("://",$url); $ex_str = $str." ".$url." > ".$d[1].".html"; //$ex_str = $str." ".$url; //echo $ex_str; //$ex_str = escapeshellarg($ex_str); //echo $ex_str; exec($ex_str, $out); //print_r($out); } } //$data = file('sites.txt'); $data_f = file('sites_x.txt'); print_r($data_f); $data = array(); $data_size = count($data_f); for($i = 0;$i<$data_size;$i++) { $info = explode(";",trim($data_f[$i])); if($info[1] === 'y') continue; $data[] = $info[0]; } print_r($data); $data_size = count($data); // Worker pool $workers = []; $t_count = 4; $flag = 1; $k = 0; //echo "$data_size"; while($flag === 1) { / //echo "$k\n"; if($k >= $data_size) { //echo "111"; exit(); $flag = 0; break 2; } / $c_w = count($workers); if($c_w < $t_count) { for($i = $c_w; $i<$t_count - $c_w;$i++) { if($k >= $data_size) { $flag = 0; break; } $workers[$i] = new WorkerThreads($data[$k]); //echo $data[$k]."\n"; echo "worker $i started\n"; $workers[$i]->start(); $k++; } } $c_w = count($workers); for($i=0;$i<$c_w;$i++) { $workers[$i]->kill(); unset($workers[$i]); echo "unset $i\n"; //var_dump($workers[$i]->isTerminated(), $workers[$i]->getTerminationInfo()); / if($workers[$i]->join()) { //var_dump($workers[$i]->isTerminated(), $my->getTerminationInfo()); echo "joining $i\n"; unset($workers[$i]); } / } } ?> Мне нужно реализовать таймаут у потока, если программа, которую он выполняет зависла, например более чем на 60 секунд. Как это сделать? Еще не понятно почему, у меня $workers[$i]->kill(); возвращает false. В чем может быть проблема? Спасибо (Отредактировано автором: 11 Апреля, 2015 - 15:39:35)*

DeepVarvar	Отправлено: 12 Апреля, 2015 - 00:24:35
Активный участник Покинул форум Сообщений всего: 10377 Дата рег-ции: Дек. 2008 Откуда: Альфа Центавра Помог: 353 раз(а)	Не нужно вообще раскалупывать этот полурабочий овощ на обдутом матрасе. Есть куча межОСевых проблем с тредами пых-пыха, кроме того, он еще и не умеет все, что должны уметь треды, тем более по POSIX-стандартам (как минимум join, detach, SIG_*). Отсюда вытекает следующая архитектура: 1) Запускать не потоки, а процессы, хош через exec() хош через что, передавая нужные параметры запускаемым процессам. 2) Для общих данных между этими процессами (мы же имитируем потоки, да?) можно, и даже нужно, использовать shared memory + semaphores. Но! Будь осторожен: у пых-пыха есть две реализации шареда, одна - только его внутреняя "виртуальная" и никакие внешние процессы не смогут увидеть и прочитать из неё, что либо, точнее прочитать то прочитают, но там будет пыхо-опкод какой-то, вторая - реальная, которая выделяет реальный кусок памяти и туда можно писать-читать межпроцессно! всякую бинарщину. Если же по каким-то причинам шаред будет не доступен (как модуль апача, не кли, не цги), можешь погонять данные между процесами тупо через файлы и их эксклюзивную пыхоблокировку LOCK_EX/LOCK_UN. Блокировка файла в целом сымитирует семафоры для шареда. 3) Управлять всеми этими "потоками" ты будешь из главного скрипта, его кстати можно и не крутить постоянно в бесконечном цикле, а так, зашел, спросил статус, выполнил действие. Как узнать что "поток" сдох? Пусть новый "поток" пишет в шаред или файл что он начал свою работу (ессно + время старта + PID + другая хрень по желанию), а по окончании - удаляет из стека себя любимого. Так мониторный скрипт сможет увидеть, что "поток" сдох, узнав что запись трудоголика не удалена, т.е. даже с PID-файлами можно будет не заморачиваться - пусть "потоки" пишут о себе прямо в шаред или файл. Аглы? ----- Шта? Репозиторий?

LIME	Отправлено: 12 Апреля, 2015 - 06:28:36
Активный участник Покинул форум Сообщений всего: 10732 Дата рег-ции: Нояб. 2010 Помог: 322 раз(а)	Или Gearman

freelsd	Отправлено: 12 Апреля, 2015 - 07:28:07
Гость Покинул форум Сообщений всего: 108 Дата рег-ции: Февр. 2015 Помог: 1 раз(а)	DeepVarvar пишет: Не нужно вообще раскалупывать этот полурабочий овощ на обдутом матрасе. Есть куча межОСевых проблем с тредами пых-пыха, кроме того, он еще и не умеет все, что должны уметь треды, тем более по POSIX-стандартам (как минимум join, detach, SIG_). Отсюда вытекает следующая архитектура: 1) Запускать не потоки, а процессы, хош через exec() хош через что, передавая нужные параметры запускаемым процессам. 2) Для общих данных между этими процессами (мы же имитируем потоки, да?) можно, и даже нужно, использовать shared memory + semaphores. Но! Будь осторожен: у пых-пыха есть две реализации шареда, одна - только его внутреняя "виртуальная" и никакие внешние процессы не смогут увидеть и прочитать из неё, что либо, точнее прочитать то прочитают, но там будет пыхо-опкод какой-то, вторая - реальная, которая выделяет реальный кусок памяти и туда можно писать-читать межпроцессно! всякую бинарщину. Если же по каким-то причинам шаред будет не доступен (как модуль апача, не кли, не цги), можешь погонять данные между процесами тупо через файлы и их эксклюзивную пыхоблокировку LOCK_EX/LOCK_UN. Блокировка файла в целом сымитирует семафоры для шареда. 3) Управлять всеми этими "потоками" ты будешь из главного скрипта, его кстати можно и не крутить постоянно в бесконечном цикле, а так, зашел, спросил статус, выполнил действие. Как узнать что "поток" сдох? Пусть новый "поток" пишет в шаред или файл что он начал свою работу (ессно + время старта + PID + другая хрень по желанию), а по окончании - удаляет из стека себя любимого. Так мониторный скрипт сможет увидеть, что "поток" сдох, узнав что запись трудоголика не удалена, т.е. даже с PID-файлами можно будет не заморачиваться - пусть "потоки" пишут о себе прямо в шаред или файл. Аглы? Спасибо конечно, что подробно расписал, но во-первых я нубас, и мне придется подробно по каждому пункту перечитывать маны. А во-вторых, не хотелось бы еще такие костыли сколачивать. Хотелось бы понять что не так и исправить. LIME пишет:* Или Gearman Вроде какое-то громоздкое решение, не? Мне в общем-то тривиальную довольно задачу нужно решить, посему хотелось бы максимально простыми способами.

DeepVarvar	Отправлено: 12 Апреля, 2015 - 10:35:35
Активный участник Покинул форум Сообщений всего: 10377 Дата рег-ции: Дек. 2008 Откуда: Альфа Центавра Помог: 353 раз(а)	Ыыыы... Ну вот еще одна идея либу написать, которую сам тут расписал. Жаль только времени нет нафига.. ----- Шта? Репозиторий?

freelsd	Отправлено: 12 Апреля, 2015 - 11:45:48
Гость Покинул форум Сообщений всего: 108 Дата рег-ции: Февр. 2015 Помог: 1 раз(а)	DeepVarvar пишет: Ыыыы... Ну вот еще одна идея либу написать, которую сам тут расписал. Жаль только времени нет нафига.. А есть какие-нибудь мысли почему kill() может не работать?

Поиск в теме | Версия для печати

Страниц (1): [1]

Сейчас эту тему просматривают: 0 (гостей: 0, зарегистрированных: 0)

« Программирование на PHP »

Все гости форума могут просматривать этот раздел.
Только зарегистрированные пользователи могут создавать новые темы в этом разделе.
Только зарегистрированные пользователи могут отвечать на сообщения в этом разделе.