Multi-threading dimungkinkan di php

Ya, Anda dapat melakukan multi-threading di PHP dengan pthreads

Dari dokumentasi PHP:

pthreads adalah API berorientasi objek yang menyediakan semua alat yang diperlukan untuk multi-threading di PHP. Aplikasi PHP dapat membuat, membaca, menulis, mengeksekusi dan melakukan sinkronisasi dengan objek Threads, Workers dan Threaded.

Peringatan: Ekstensi pthreads tidak dapat digunakan di lingkungan server web. Oleh karena itu, threading di PHP harus tetap hanya untuk aplikasi berbasis CLI saja.

Tes Sederhana

#!/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();
}

?>

Lari pertama

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

Jalankan Kedua

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

Contoh Dunia Nyata

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);
}

kenapa Anda tidak menggunakan popen?

for ($i=0; $i<10; $i++) {
    // open ten processes
    for ($j=0; $j<10; $j++) {
        $pipe[$j] = popen('script2.php', 'w');
    }

    // wait for them to finish
    for ($j=0; $j<10; ++$j) {
        pclose($pipe[$j]);
    }
}

Threading tidak tersedia dalam stok PHP, tetapi pemrograman bersamaan dimungkinkan dengan menggunakan permintaan HTTP sebagai panggilan asinkron.

Dengan pengaturan batas waktu curl disetel ke 1 dan menggunakan session_id yang sama untuk proses yang ingin Anda kaitkan satu sama lain, Anda dapat berkomunikasi dengan variabel sesi seperti pada contoh saya di bawah ini. Dengan metode ini Anda bahkan dapat menutup browser Anda dan proses bersamaan masih ada di server.

Jangan lupa untuk memverifikasi ID sesi yang benar seperti ini:

http://localhost/test/verifysession.php?sessionid=[the id yang benar ]

proses mulai.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"];

proses1.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);
}

verifikasisesi.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);

Meskipun Anda tidak dapat melakukan thread, Anda memiliki tingkat kontrol proses tertentu di php. Dua kumpulan fungsi yang berguna di sini adalah:

Fungsi kontrol proses http://www.php.net/manual/en/ref.pcntl.php

Fungsi POSIX http://www.php.net/manual/en/ref.posix.php

Anda dapat membagi proses Anda dengan pcntl_fork - mengembalikan PID anak tersebut. Kemudian Anda dapat menggunakan posix_kill untuk menghapus PID itu.

Artinya, jika Anda mematikan proses induk, sinyal harus dikirim ke proses anak yang memerintahkannya untuk mati. Jika php sendiri tidak mengenalinya, Anda dapat mendaftarkan fungsi untuk mengelolanya dan melakukan exit bersih menggunakan pcntl_signal.

penggunaan thread dimungkinkan oleh ekstensi PECL pthreads

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

Saya tahu ini adalah pertanyaan lama tetapi bagi orang yang mencari, ada ekstensi PECL yang ditulis dalam C yang memberikan kemampuan multi-threading PHP sekarang, terletak di sini https://github.com/krakjoe/pthreads

Anda dapat menggunakan exec() untuk menjalankan skrip baris perintah (seperti baris perintah php), dan jika Anda menyalurkan output ke file maka skrip Anda tidak akan menunggu hingga perintah selesai.

Saya tidak begitu ingat sintaks php CLI, tetapi Anda menginginkan sesuatu seperti:

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

Saya pikir beberapa server hosting bersama telah menonaktifkan exec() secara default karena alasan keamanan, tetapi mungkin patut dicoba.

Anda bisa mensimulasikan threading. PHP dapat menjalankan proses latar belakang melalui popen (atau proc_open). Proses-proses tersebut dapat dikomunikasikan melalui stdin dan stdout. Tentu saja proses-proses itu sendiri bisa menjadi program php. Itu mungkin sedekat yang Anda dapatkan.

Anda dapat memiliki pilihan:

1. multi_ikal
2. Seseorang dapat menggunakan perintah sistem untuk hal yang sama
3. Skenario yang ideal adalah, membuat fungsi threading dalam bahasa C dan mengkompilasi/mengkonfigurasi dalam PHP. Sekarang fungsi itu akan menjadi fungsi PHP.

Bagaimana dengan pcntl_fork?

periksa halaman manual kami untuk contoh: 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
    }

?>

Bergantung pada apa yang Anda coba lakukan, Anda juga bisa menggunakan curl_multi untuk mencapainya.

Jika Anda menggunakan server Linux, Anda dapat menggunakan

exec("nohup $php_path path/script.php > /dev/null 2>/dev/null &")

Jika Anda perlu menyampaikan beberapa argumen

exec("nohup $php_path path/script.php $args > /dev/null 2>/dev/null &")

Di skrip.php

$args = $argv[1];

Atau gunakan Symfony https://symfony.com/doc/current/components/process.html

$process = Process::fromShellCommandline("php ".base_path('script.php'));
$process->setTimeout(0);     
$process->disableOutput();     
$process->start();

pcntl_fork tidak akan berfungsi di lingkungan server web jika mode aman diaktifkan. Dalam hal ini, ini hanya akan berfungsi di PHP versi CLI.

Mungkin saya melewatkan sesuatu tetapi exec tidak berfungsi secara asinkron untuk saya di lingkungan windows saya menggunakan yang berikut di windows dan itu berfungsi dengan baik;)

$script_exec = "c:/php/php.exe c:/path/my_ascyn_script.php";

pclose(popen("start /B ". $script_exec, "r"));

Saat komentar saya saat ini ditulis, saya tidak tahu tentang thread PHP. Saya sendiri datang untuk mencari jawabannya di sini, tetapi salah satu solusinya adalah program PHP yang menerima permintaan dari server web mendelegasikan seluruh formulasi jawaban ke aplikasi konsol yang menyimpan outputnya, jawaban atas permintaan, ke file biner dan program PHP yang meluncurkan aplikasi konsol mengembalikan file biner byte demi byte sebagai jawaban atas permintaan yang diterima. Aplikasi konsol dapat ditulis dalam bahasa pemrograman apa pun yang berjalan di server, termasuk bahasa yang memiliki dukungan threading yang tepat, termasuk program C++ yang menggunakan OpenMP.

Salah satu trik yang tidak dapat diandalkan dan kotor adalah dengan menggunakan PHP untuk menjalankan aplikasi konsol, "uname",

uname -a

dan cetak output dari perintah konsol tersebut ke output HTML untuk mengetahui versi pasti dari perangkat lunak server. Kemudian instal versi perangkat lunak yang sama persis ke instance VirtualBox, kompilasi/rakit biner apa pun yang sepenuhnya mandiri, sebaiknya statis, yang diinginkan, lalu unggah ke server. Sejak saat itu, aplikasi PHP dapat menggunakan biner tersebut sebagai aplikasi konsol yang memiliki multi-threading yang tepat. Ini adalah solusi yang kotor dan tidak dapat diandalkan untuk situasi ketika administrator server belum menginstal semua implementasi bahasa pemrograman yang diperlukan ke server. Hal yang harus diwaspadai adalah setiap permintaan yang diterima aplikasi PHP, aplikasi konsol akan dihentikan/keluar/get_killed.

Mengenai apa yang dipikirkan oleh administrator layanan hosting tentang pola penggunaan server seperti itu, saya kira itu bermuara pada budaya. Di Eropa Utara, penyedia layanan HARUS MEMBERIKAN APA YANG DIIKLANKAN dan jika eksekusi perintah konsol diizinkan dan pengunggahan file non-malware diizinkan dan penyedia layanan berhak mematikan proses server apa pun setelah beberapa menit atau bahkan setelah 30 detik , maka administrator layanan hosting tidak memiliki argumen untuk mengajukan keluhan yang tepat. Di Amerika Serikat dan Eropa Barat situasinya/budayanya sangat berbeda dan saya yakin ada kemungkinan besar bahwa di AS dan/atau Eropa Barat penyedia layanan hosting akan menolak melayani klien layanan hosting yang menggunakan trik yang dijelaskan di atas. Itu hanya tebakan saya, mengingat pengalaman pribadi saya dengan layanan hosting AS dan berdasarkan apa yang saya dengar dari orang lain tentang layanan hosting Eropa Barat. Saat komentar saya saat ini ditulis (2018_09_01), saya tidak tahu apa pun tentang norma budaya penyedia layanan hosting Eropa Selatan, administrator jaringan Eropa Selatan.

Multithreading berarti melakukan banyak tugas atau proses secara bersamaan, kita dapat mencapainya di php dengan menggunakan kode berikut, meskipun tidak ada cara langsung untuk mencapai multithreading di php tetapi kita dapat mencapai hasil yang hampir sama dengan cara berikut.

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 .

}

Tes_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() ");

}

Ini akan mengeksekusi test_1.php dua kali secara bersamaan dan kedua proses akan berjalan di latar belakang secara bersamaan, jadi dengan cara ini Anda bisa mencapai multithreading di php.

Orang ini melakukan pekerjaan yang sangat bagus Membuat multithread di php