PHP thread Opcje

[sasiadstar]

Witam
Mam taki kod testowy

[PHP] pobierz, plaintext 
<?php
ini_set('display_errors', 0);
class CheckIpThread extends Thread {
    private $ip;
    public $data = null;
 
    public function __construct ($ip_to_check) {
       $this->ip = $ip_to_check;
    }
 
    public function run () {
       $this->data = th($this->ip);
    }
}
$threads = [];
 
for($a=0;$a<=1000;$a=$a+100)
{licz($a);}
function licz($co)
{
	for($a=0;$a<=100;$a++)
	{//echo_($a);
    $thread = new CheckIpThread($co+$a);
    $threads []= $thread;
    $thread->start();   
}
foreach ($threads as $thread) {
    $thread->join();
}
 
foreach ($threads as $thread) {
    echo_($thread->data);
}
}
 
 
function th($wsad)
{return $wsad;//jakies tam obliczenia
}
 
function echo_($tekst,$def=0)
{
       ob_flush();
       flush();
        usleep(200);
		if($def===0)
		{var_dump($tekst);}
	if($def===1)
		{echo($tekst);}
		echo"</br>";
 
ob_end_flush();
 
}
?>
[PHP] pobierz, plaintext 

Kod wypluwa liczby od 0 do 799 i przestaje dalej sie wykonywać cały czas przegladarka "kręci" i na tym sie temat kończy.
O co kaman?

Ten post edytował sasiadstar 14.08.2017, 13:32:55

[Puszy]

Z ciekawości, odpal to przez CLI i sprawdź wynik.

[sasiadstar]

Hmmm
CLI działa.
Poszedłem za ciosem edge działa.
Innych przeglądarek nie mam.
No ciekawe.

Aktualizacja
Zwiększyłem wartość do wyliczenia i wywaliło błąd a po powrocie do 2000 jest to samo.
PHP Fatal error: Uncaught exception 'RuntimeException' with message 'pthreads has detected that the CheckIpThread could not be started, the system lacks the necessary resources or the system-imposed limit would be exceeded' in C:\xampp\htdocs\test\Benchmark.php:34
Stack trace:
#0 C:\xampp\htdocs\test\Benchmark.php(34): Thread->start()
#1 C:\xampp\htdocs\test\Benchmark.php(22): th_(900)
#2 {main}
thrown in C:\xampp\htdocs\test\Benchmark.php on line 34

[Puszy]

U mnie na produkcji jest jakoś tak ustawiony Apache że strona ładuje się 30 sekund i zawracany jest bodajże 500, nie idzie tego zmienić od strony kodu. Dlatego wiele akcji musiałem przerzucić na CLI i odpalać CRONem. Wygląda na to że nie starcza zasobów serwera.

[sasiadstar]

No właśnie a wiem że da się to zrobić tylko sie używa jakichś workerów pooli i czego tam jeszcze, poprostu nie wiem jak to zrobić.
Znalazłem taki kod który działa tak jak bym tego chciał ale nie wiem jak to poprzerabiać niestety za tepy jestem w klasach.
Chciałbym żeby w tym miejscu

[PHP] pobierz, plaintext 
for($a=0;$a<=10000;$a++)
{$pool->submit(new MyWork($a));}
//return wynik
 
 
[PHP] pobierz, plaintext 

mozna bylo miec wynik wszystkich operacji a nie tam gdzie jest echo

[PHP] pobierz, plaintext 
<?php
ini_set('display_errors', 0);
set_time_limit(0);
ini_set('default_socket_timeout', 3);
class MyWork extends Threaded {
 
    public $name;
 
    public function __construct($name) {
 
        $this->name = $name;
    }
 
    public function run() {       
            echo_( $this->name );       
 
    }
 
}
 
class MyWorker extends Worker {
    public function run() {}
}
 
$pool = new Pool(50, \MyWorker::class);
for($a=0;$a<=10000;$a++)
{$pool->submit(new MyWork($a));}
 
$pool->shutdown();
 
function echo_($tekst,$def=0)
{
       ob_flush();
       flush();
        //usleep(200);
	if($def===0)
		{var_dump($tekst);}
	if($def===1)
		{echo($tekst);}
		echo"</br>";
 
ob_end_flush();
ob_clean();		
}
?>
 
 
 
 
[PHP] pobierz, plaintext