Wie kann man die Verwendung von multi-threading in PHP-Anwendungen

Multi-threading möglich ist in php

Ja, Sie können tun, multi-threading in PHP mit pthreads

Vom die PHP-Dokumentation:

pthreads ist eine Objekt-orientierte API, bietet alle Werkzeuge, die Sie für multi-threading in PHP. PHP-Anwendungen erstellen können, Lesen, schreiben, ausführen und synchronisieren Sie Sie mit Fäden, die Arbeiter und die Objekte mit Gewinde.

Warnung:
Der pthreads extension nicht verwendet werden, in eine web-server-Umgebung. Threading in PHP sollten deshalb weiterhin auf CLI-basierte Anwendungen nur.

Einfachen Test

#!/usr/bin/php
<?php
class AsyncOperation extends Thread {

    public function __construct($arg) {
        $this->arg = $arg;
    }

    public function run() {
        if ($this->arg) {
            $sleep = mt_rand(1, 10);
            printf('%s: %s  -start -sleeps %d' . "\n", date("g:i:sa"), $this->arg, $sleep);
            sleep($sleep);
            printf('%s: %s  -finish' . "\n", date("g:i:sa"), $this->arg);
        }
    }
}

//Create a array
$stack = array();

//Initiate Multiple Thread
foreach ( range("A", "D") as $i ) {
    $stack[] = new AsyncOperation($i);
}

//Start The Threads
foreach ( $stack as $t ) {
    $t->start();
}

?>

Ersten Lauf

12:00:06pm:     A  -start -sleeps 5
12:00:06pm:     B  -start -sleeps 3
12:00:06pm:     C  -start -sleeps 10
12:00:06pm:     D  -start -sleeps 2
12:00:08pm:     D  -finish
12:00:09pm:     B  -finish
12:00:11pm:     A  -finish
12:00:16pm:     C  -finish

Zweiten Lauf

12:01:36pm:     A  -start -sleeps 6
12:01:36pm:     B  -start -sleeps 1
12:01:36pm:     C  -start -sleeps 2
12:01:36pm:     D  -start -sleeps 1
12:01:37pm:     B  -finish
12:01:37pm:     D  -finish
12:01:38pm:     C  -finish
12:01:42pm:     A  -finish

Realen Welt Beispiel

error_reporting(E_ALL);
class AsyncWebRequest extends Thread {
    public $url;
    public $data;

    public function __construct($url) {
        $this->url = $url;
    }

    public function run() {
        if (($url = $this->url)) {
            /*
             * If a large amount of data is being requested, you might want to
             * fsockopen and read using usleep in between reads
             */
            $this->data = file_get_contents($url);
        } else
            printf("Thread #%lu was not provided a URL\n", $this->getThreadId());
    }
}

$t = microtime(true);
$g = new AsyncWebRequest(sprintf("http://www.google.com/?q=%s", rand() * 10));
/* starting synchronization */
if ($g->start()) {
    printf("Request took %f seconds to start ", microtime(true) - $t);
    while ( $g->isRunning() ) {
        echo ".";
        usleep(100);
    }
    if ($g->join()) {
        printf(" and %f seconds to finish receiving %d bytes\n", microtime(true) - $t, strlen($g->data));
    } else
        printf(" and %f seconds to finish, request failed\n", microtime(true) - $t);
}

Threading ist nicht im Lager verfügbar PHP, aber die Programmierung ist möglich durch die Verwendung von HTTP-Anforderungen als asynchrone Aufrufe.

Mit den curl-timeout-Einstellung auf 1 gesetzt und das gleiche session_id für die Prozesse, die Sie wollen, verbunden zu sein mit einander, können Sie die Kommunikation mit session-Variablen, wie in meinem Beispiel unten. Mit dieser Methode können Sie auch den browser schließen und die Auger-Prozess immer noch auf dem server vorhanden ist.

Vergessen Sie nicht, überprüfen Sie die korrekte session-ID, wie diese:

http://localhost/test/verifysession.php?sessionid=%5Bdie richtige id]

startprocess.php

$request = "http://localhost/test/process1.php?sessionid=".$_REQUEST["PHPSESSID"];
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, $request);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
curl_setopt($ch, CURLOPT_TIMEOUT, 1);
curl_exec($ch);
curl_close($ch);
echo $_REQUEST["PHPSESSID"];

process1.php

set_time_limit(0);

if ($_REQUEST["sessionid"])
   session_id($_REQUEST["sessionid"]);

function checkclose()
{
   global $_SESSION;
   if ($_SESSION["closesession"])
   {
       unset($_SESSION["closesession"]);
       die();
   }
}

while(!$close)
{
   session_start();
   $_SESSION["test"] = rand();
   checkclose();
   session_write_close();
   sleep(5);
}

verifysession.php

if ($_REQUEST["sessionid"])
    session_id($_REQUEST["sessionid"]);

session_start();
var_dump($_SESSION);

closeprocess.php

if ($_REQUEST["sessionid"])
    session_id($_REQUEST["sessionid"]);

session_start();
$_SESSION["closesession"] = true;
var_dump($_SESSION);

Verwendung von threads ist möglich durch die pthreads-PECL-Erweiterung

http://www.php.net/manual/en/book.pthreads.php

Können Sie mit exec() zum ausführen eines Kommandozeilen-Skript (wie z.B. Kommandozeilen-php) und falls du leiten Sie die Ausgabe in eine Datei dann ist dein script nicht wartet, bis der Befehl fertig stellen.

Kann ich nicht ganz vergessen, die php-CLI-syntax, aber Sie wollen würde, so etwas wie:

exec("/path/to/php -f '/path/to/file.php' | '/path/to/output.txt'");

Denke ich durchaus ein paar shared-hosting-Server haben, exec() standardmäßig deaktiviert aus Sicherheitsgründen, aber vielleicht einen Versuch Wert.

Wie etwa pcntl_fork?

überprüfen Sie bitte die manual-Seite für Beispiele: PHP pcntl_fork

<?php

    $pid = pcntl_fork();
    if ($pid == -1) {
        die('could not fork');
    } else if ($pid) {
        //we are the parent
        pcntl_wait($status); //Protect against Zombie children
    } else {
        //we are the child
    }

?>

Ich weiß, das ist alt, aber man konnte sich bei http://phpthreadlib.sourceforge.net/

Es unterstützt die bidirektionale inter-thread-Kommunikation und hat auch eingebaute Schutzmechanismen, die für das töten von Kind threads (Vermeidung von Waisen).

Können Sie haben die Möglichkeit:

1. multi_curl
2. Kann man verwenden, um system-Befehl für die gleiche
3. Ideale Szenario ist, erstellen Sie ein threading-Funktion in der Programmiersprache C und kompilieren/konfigurieren in PHP. Nun, die Funktion wird die Funktion von PHP.

Als das schreiben meiner aktuellen Kommentar, ich weiß nicht über die PHP-threads. Ich kam, um sich für die Antwort, mich hier, aber ein workaround ist, dass das PHP-Programm, das erhält die Anfrage vom web-server delegiert die ganze Antwort-Formulierung, um eine Konsole-Anwendung, die speichert seine Ausgabe, die Antwort auf die Anfrage, um eine Binär-Datei und das PHP-Programm, dass gestartet die Konsole-Anwendung gibt, die Binär-Datei byteweise als Antwort auf die empfangene Anfrage. Die Konsole-Anwendung kann in einer beliebigen Programmiersprache geschrieben, die auf dem server ausgeführt wird, einschließlich derjenigen, die richtigen threading-Unterstützung, einschließlich der C++ - Programmen, die mit OpenMP.

Einer unzuverlässigen, schmutzigen trick ist die Verwendung von PHP für die Ausführung einer Konsolenanwendung, "uname",

uname -a

ausdrucken und die Ausgabe der console-Befehl, um die HTML-Ausgabe, um herauszufinden, die genaue version der server-software. Installieren Sie dann die exakt gleiche version der software, um eine VirtualBox-Instanz, zu kompilieren/assemblieren, was vollständig in sich geschlossene, vorzugsweise statische, die Programme, die man will und dann laden diese auf den server. Von diesem Zeitpunkt an die PHP-Anwendung verwenden können, die Binärdateien, die in der Rolle der Konsole-Anwendung, die richtige multi-threading. Es ist ein schmutzig, unzuverlässig, Abhilfe für die situation, wenn der server-administrator hat die nicht installiert alle benötigten Programmier-Sprache-Implementierungen auf der server. Die Sache zu beachten ist, dass bei jeder Anfrage, dass die PHP-Anwendung erhält der console-Anwendung(en) beendet/beenden/get_killed.

Als zu dem, was die hosting-service-Administratoren meinen, dass solche server Nutzungsmuster, ich denke, es läuft darauf hinaus, Kultur. Im nördlichen Europa wird der service-Anbieter HAT ZU LIEFERN, WAS ANGEKÜNDIGT WURDE und wenn die Ausführung der Befehle in console war erlaubt und das hochladen von nicht-malware-Dateien erlaubt war, und der service provider hat das Recht zu töten, die server-Prozess nach wenigen Minuten oder erst nach 30 Sekunden, dann die hosting-service-Administratoren fehlen die Argumente für die Bildung einer richtigen Beschwerde. In den Vereinigten Staaten und Westeuropa die situation/Kultur ist sehr anders und ich glaube, dass es eine große chance gibt, dass in den USA und/oder Westeuropa hosting-service-provider
weigern, zu dienen, hosting-service-clients, die mit den oben beschriebenen trick. Das ist nur meine Vermutung, da meine persönlichen Erfahrungen mit US-hosting-services und angesichts dessen, was ich von anderen gehört über die westliche Europäische hosting-services. Mit dem schreiben meines aktuellen Kommentar(2018_09_01) ich weiß nicht, etwas über die kulturellen Normen der Süd-europäischen hosting-service-Provider, Süd-Europäische Netzwerk-Administratoren.

Multithreading bedeutet, die Ausführung verschiedener Aufgaben oder Prozesse gleichzeitig, wir können dies erreichen, in php mit dem folgenden code,obwohl es keinen direkten Weg zu erreichen multithreading in php aber wir können erreichen fast die gleichen Ergebnisse, indem Sie folgenden Weg.

chdir(dirname(__FILE__));  //if you want to run this file as cron job
 for ($i = 0; $i < 2; $i += 1){
 exec("php test_1.php $i > test.txt &");
 //this will execute test_1.php and will leave this process executing in the background and will go         

 //to next iteration of the loop immediately without waiting the completion of the script in the   

 //test_1.php , $i  is passed as argument .

}

Test_1.php

$conn=mysql_connect($host,$user,$pass);
$db=mysql_select_db($db);
$i = $argv[1];  //this is the argument passed from index.php file
for($j = 0;$j<5000; $j ++)
{
mysql_query("insert  into  test   set

                id='$i',

                comment='test',

                datetime=NOW() ");

}

Diese ausgeführt wird test_1.php zwei mal gleichzeitig und beide Prozess wird im hintergrund ausgeführt, die gleichzeitig ,also in diese Weise können Sie erreichen multithreading in php.

Dieser Kerl getan wirklich gute Arbeit Multithreading in php