Php - многопоточность на уровне ОС или делаем недетерминированный аппарат

[desTiny]

Недавно пришла мне в голову одна идейка, как реализовать в PHP многопоточность. Притом настоящую, а не выдуманную. Заранее предупреждаю, что хоть идея и весьма экстравагантна, но она работает.

Итак, предположим, мы хотим подобрать пароль (в моём упрощённом случае - некое число - идентификатор). Как это можно сделать, используя многопоточность? Делим всё множество вариантов на (почти) равные части, а дальше уже для каждой части выполняем свой поток.

PHP не поддерживает многопоточность. Но PHP позволяет одновременно выполнять на сервере много PHP-скриптов... Поняли мою идею? Наша цель - чтобы php-файл до поры до времени создавал некоторые файлы (дочерние php-скрипты) и запускал их, посредством обращения к серверу, то есть к себе же. Как бы это странно не звучало, но оно работает:)

Наслаждаемся (только порт не забудте поменять, если надо, на 80):

1.php(название просто так менять НЕЛЬЗЯ!)
<?php //Coded by desTiny :-)
$start=0;
$end=100;
ini_set("max_execution_time",0);
function check($id){
if (file_exists("f.txt")){
if ($name!=1)unlink(__FILE__);
die();
}
if ($id == 79){
if ($name!=1)unlink(__FILE__);
file_put_contents("f.txt", $id);
die();
}
}

(isset($_GET['name']) && is_numeric($_GET['name']) && ($_GET['name'] > 0)) ? $name=$_GET['name'] : $name = 1;
if ($end - $start < 10)
for (; $start <= $end; $start++)
check($start);
else{
$name1 = 2 * $name; //строим хип
$name2 = 2 * $name + 1;
$st = round(($start + $end)/2);
$f = file("$name.php");
$f[1]="\$start=$start;\r\n";
$f[2]="\$end=$st;\r\n";
file_put_contents("$name1.php", $f);
$st++;
$f[1]="\$start=$st;\r\n";
$f[2]="\$end=$end;\r\n";
file_put_contents("$name2.php", $f);
$ock=fsockopen("127.0.0.1",8080);
$path=dirname($_SERVER['PHP_SELF']);
$p="GET $path\\$name1.php?name=$name1 HTTP/1.1\r\n".
"Host: 127.0.0.1\r\n".
"\r\n";
fputs($ock, $p);
fclose($ock);
$ock=fsockopen("127.0.0.1",8080);
$p="GET $path\\$name2.php?name=$name2 HTTP/1.1\r\n".
"Host: 127.0.0.1\r\n".
"\r\n";
fputs($ock, $p);
fclose($ock);
}
if ($name!=1)unlink(__FILE__);
?>

Функция check проверяет переданный ей id. У меня это - банальное сравнение с 79, но могло быть что угодно.

Ответ скрипта смотрим в файле "f.txt"


PS Разумеется, способ бредовый, но почему бы не поделиться необычной идеей? :)

(c)С вами был desTiny. Приятного просмотра =)

[Novi4ek]

Недавно пришла мне в голову одна идейка, как реализовать в PHP многопоточность. Притом настоящую, а не выдуманную.
Никакая это не многопоточность (в том смысле в котором этот термин употребляется в теории многозадачности)

Это бессмысленно довольно, т.к.
1) В php есть форки
2) Для параллельного обслуживания нескольких сетевых подключений есть неблокирующие сокеты (существуют TCP сервера на PHP без использования распараллеливания выполнения с помощью неблокирующих сокетов)
3) Есть другие языки и другие способы выполнить задачи которые ты ставишь и исполняешь через заднее место гораздо более эффективно.

PS Разумеется, способ бредовый, но почему бы не поделиться необычной идеей?

Да, и ты знаешь, эту "идею" я реализовал и описал на этом форуме году этак в 2004ом.

[groundhog]

Это бред а не многопоточность, и о каких средствах операционной системы идёт речь?

[desTiny]

Да что ж вы это так близко к сердцу приняли? :))

Ps А что это, если не многопоточность?
>>>о каких средствах операционной системы идёт речь?
в винде это называется "диспечер процессов и потоков"

[Sharky]

бред а не статья

[De-visible]

Человек поделился своей идеей, а вы бред да бред, не интересно???? Придумайте лучше!
Зачем же так? Он же сам сказал:

Ps Разумеется, способ бредовый, но почему бы не поделиться необычной идеей?
-------------
Спасибо desTiny, почитал:)...будем пробывать....
-------------

[ElteRUS]

Приделываем велосипеду крылья от самолета ...
Если разработчики пхп изначально не сделали поддержку многопоточность, значит наверно у них на то были причины, значит не нужна она там нах. А если вам лично нужна многопоточность - учите перл.

[[Raz0r]]

значит не нужна она там нах
Php6 будет поддерживать многопоточность

[ElteRUS]

']Php6 будет поддерживать многопоточность

Ну вот и отлично, значит учли многочисленные пожелания кодеров. А к чему весь этот изврат "на уровне ОС" я не понимаю.

Недетерминированный аппарат - гыгыг :D я тоже так могу, например : квазипузлистатированный коллапс Вулсторпа ))

[+toxa+]

Класс для одновременного открытия нескольких сокетов
<?
class HttpQueue
{
/**
* An array of URLs
*
* @access private
* @var array
*/
private $_urls = array();

/**
* An array of server sockets
*
* @access private
* @var array
*/
private $_sockets = array();

/**
* An array of server responses
*
* @access private
* @var array
*/
private $_response = array();

/**
* Socket timeout
*
* @access private
* @var integer
*/
private $_timeout = 30;

/**
* An array of sockets which can be received
*
* @access private
* @var array
*/
private $_read = array();

/**
* An array of sockets which can be sended
*
* @access private
* @var array
*/
private $_write = array();

/**
* Adds an URL into a tasklist
*
* @access public
* @param string $method
* @param string $url
* @return void
*/
public function add($method, $url)
{
$this->_urls[] = array(strtoupper($method), $this->_parseUrl($url));
}

/**
* Parses requested URL and checks for all URL parts
*
* @access private
* @param string $url
* @return array
*/
private function _parseUrl($url)
{
$parts = parse_url($url);
$parts['port'] = array_key_exists(’port’, $parts) ? $parts['port'] : 80;
$parts['sock'] = sprintf(’%s:%s’, $parts['host'], $parts['port']);
$parts['request'] = sprintf(’%s?%s’, $parts['path'], $parts['query']);
return $parts;
}

/**
* Starts fetch process
*
* @access public
* @param void
* @return array
*/
public function fetch()
{
$this->_create();
$this->_process();
return $this->toArray();
}

/**
* Sets socket timeout (in seconds)
*
* @access public
* @param integer $timeout
* @return void
*/
public function setTimeout($timeout)
{
$this->_timeout = $timeout;
}

/**
* Returns array of server responses
*
* @access public
* @param void
* @return array
*/
public function toArray()
{
return $this->_response;
}

/**
* Creates socket conenctions with hosts given in URL
*
* @access private
* @param void
* @return void
*/
private function _create()
{
foreach ($this->_urls as $id => $connect) {
if ($socket = @stream_socket_client($connect[1]['sock'], $errno,
$errstr, $this->_timeout,
STREAM_CLIENT_ASYNC_CONNECT|STREAM_CLIENT_CONNECT) ) {
$this->_sockets[$id] = $socket;
$this->_response[$id] = ‘processing’;
continue;
}

$this->_response[$id] = “failed, $errno $errstr”;
}
}

/**
* Process opened sockets
*
* @access private
* @param void
* @return void
*/
private function _process()
{
while (count($this->_sockets)) {
$this->_read = $this->_sockets;
$this->_write = $this->_sockets;

$select = stream_select($this->_read, $this->_write, $e = null,
$this->_timeout);

if ($select > 0) {
$this->_read();
$this->_write();
}

else {
foreach ($this->_sockets as $id => $s) {
$this->_response[$id] = ‘Timed out’;
}

break;
}
}
}

/**
* Receives data from readable socket
*
* @access private
* @param void
* @return void
*/
private function _read()
{
foreach ($this->_read as $fp) {
$id = array_search($fp, $this->_sockets);
$data = fread($fp, 8192);

if (strlen($data) == 0) {
if ($this->_response[$id] == ‘processing’) {
$this->_response[$id] = ‘failed to connect’;
}

fclose($fp);
unset($this->_sockets[$id]);
}

else {
$this->_response[$id].= $data;
}
}
}

/**
* Sends HTTP request into writeable socket
*
* @access private
* @param void
* @return void
*/
private function _write()
{
foreach ($this->_write as $fp) {
$id = array_search($fp, $this->_sockets);
$method = $this->_urls[$id][0];
$request = $this->_urls[$id][1]['request'];
$host = $this->_urls[$id][1]['host'];

fputs($fp, “$method $request HTTP/1.0rn”);
fputs($fp, “Host: $hostrnrn”);

$this->_response[$id] = ”;
}
}
}
?>