Bagaimana seseorang dapat menggunakan multi threading dalam aplikasi PHP

414

Apakah ada cara realistis untuk mengimplementasikan model multi-threaded di PHP baik benar, atau hanya mensimulasikannya. Beberapa waktu lalu disarankan agar Anda dapat memaksa sistem operasi untuk memuat contoh lain dari executable PHP dan menangani proses simultan lainnya.

Masalah dengan ini adalah bahwa ketika kode PHP selesai mengeksekusi instance PHP tetap ada dalam memori karena tidak ada cara untuk membunuhnya dari dalam PHP. Jadi jika Anda mensimulasikan beberapa utas, Anda dapat membayangkan apa yang akan terjadi. Jadi saya masih mencari cara multi-threading dapat dilakukan atau disimulasikan secara efektif dari dalam PHP. Ada ide?

Steve Obbayi
sumber
1
Lihat pertanyaan dan jawaban saya di sini: stackoverflow.com/questions/2101640/…
powtac
1
... dan milikku di sini: stackoverflow.com/questions/209774/does-php-have-threading/…
Francois Bourgeois
cara menggunakan ekstensi pthreads: phplobby.com/php-multi-thread-on-windows-pthreads-configuration
Emrah Mehmedov
Mungkin menarik: pthreads.org
GibboK
Sekarang pada tahun 2020, tampaknya "paralel" php.net/manual/en/intro.parallel.php adalah yang kita inginkan daripada "pthreads": stackoverflow.com/a/56451969/470749
Ryan

Jawaban:

431

Multi-threading dimungkinkan dalam php

Ya, Anda bisa melakukan multi-threading dalam 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, menjalankan dan menyinkronkan dengan Thread, Pekerja dan objek Thread.

Peringatan : Ekstensi pthreads tidak dapat digunakan di lingkungan server web. Threading dalam PHP karena itu harus tetap hanya untuk aplikasi berbasis CLI.

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);
}
Baba
sumber
3
@Baba, saya tidak dapat mengkonfigurasi dan menginstal pthreads di server Xampp. Bisakah Anda membantu saya dengan itu?
Irfan
4
Unduh binary windows di sini windows.php.net/downloads/pecl/releases/pthreads/0.0.45
Baba
17
Itu bagus, saya belum menyentuh PHP selama bertahun-tahun dan sekarang punya kemampuan multithreading!
Cruizer
1
Bagus dan sederhana! Hanya FYI, saya menggunakan aplikasi pada server Azure Cloud Win dan jika hanya konfigurasi dasar 1 inti yang dipilih multi-threading tidak akan tersedia kecuali lebih banyak core ditambahkan.
Milan
3
Harap hati-hati: Joe Watkins, penulis ekstensi pthreads menghentikan pengembangan demi ekstensi paralel baru: github.com/krakjoe/pthreads/issues/929
Anton Belonovich
42

kenapa kamu 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]);
    }
}
masterb
sumber
4
Saya menggunakan solusi di atas, dan berfungsi dengan baik, saya pikir itu adalah cara paling mudah untuk melakukan proses paralel menggunakan php.
GodFather
7
seperti @ e-info128 mengatakan, implementasi ini mem-fork proses, yang artinya berjalan pada proses yang berbeda, dan tidak berbagi sumber daya proses. Yang sedang berkata, jika pekerjaan yang dihadapi tidak perlu berbagi sumber daya, maka ini akan tetap bekerja dan itu akan berjalan secara paralel.
Raffi
1
Bagaimana Anda meneruskan variabel ke popen tanpa menggunakan variabel sesi?
atwellpub
@ atwellpub Tidak mungkin, ini adalah proses terpisah yang tidak berbagi sumber daya. Bahkan sesi akan menjadi mekanisme IPC yang canggung
Cholthi Paul Ttiopic
1
Untuk mengirimkan data kepada mereka, Anda dapat menggunakan argumen dan server Redis juga.
Amir Fo
21

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

Dengan pengaturan batas waktu curl diatur ke 1 dan menggunakan session_id yang sama untuk proses yang Anda ingin dikaitkan satu sama lain, Anda dapat berkomunikasi dengan variabel sesi seperti dalam 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 = [ id yang benar]

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);
Ricardo
sumber
4
Terakhir kali saya memeriksa (beberapa tahun yang lalu) php tidak mengizinkan untuk mengakses penyimpanan sesi berbasis file oleh dua proses secara bersamaan. Itu mengunci file dan proses kedua harus duduk di sana menunggu skrip pertama berhenti. Saya berbicara tentang lingkungan server web, bukan CLI.
Alexei Tenitski
5
set_time_limit(0);Astaga! Tidak pernah melakukan ini.
Kafoso
@ Kafoso Kafoso kenapa tidak? Yah saya setuju untuk PHP sebagai prosesor skrip web, tapi mengapa tidak di CLI? Jika terjadi kesalahan, CLI dapat dibunuh dengan Ctrl + C ...
sijanec
14

Meskipun Anda tidak dapat utas, Anda memiliki beberapa tingkat kendali proses di php. Dua set 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 melakukan proses fork dengan pcntl_fork - mengembalikan PID anak. Kemudian Anda dapat menggunakan posix_kill untuk menolak PID itu.

Yang mengatakan, jika Anda membunuh proses orang tua sinyal harus dikirim ke proses anak mengatakan itu untuk mati. Jika php sendiri tidak mengenali ini, Anda bisa mendaftarkan fungsi untuk mengelolanya dan melakukan jalan keluar yang bersih menggunakan pcntl_signal.

JD Fitz. Emerald
sumber
1
Jawaban itu sekarang sangat usang (yang sangat adil mengetahui bahwa ia berusia 11 tahun). Lihatlah pthreads di bawah ini.
Maciej Paprocki
@MaciejPaprocki pThread sekarang dihentikan fromphp 7.4 sebagai gantinya menggunakan paralel
Airy
10

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, itu terletak di sini https://github.com/krakjoe/pthreads

JasonDavis
sumber
pThread sekarang dihentikan dari php 7.4 sebagai gantinya menggunakan paralel
Airy
5

Anda dapat menggunakan exec () untuk menjalankan skrip baris perintah (seperti php baris perintah), dan jika Anda mengirim output ke file, skrip Anda tidak akan menunggu 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 memiliki exec () dinonaktifkan secara default untuk alasan keamanan, tetapi mungkin patut dicoba.

Adam Hopkinson
sumber
4

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 itu sendiri dapat menjadi program php. Itu mungkin sedekat yang Anda dapatkan.

Pete
sumber
3

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

Sheldmandu
sumber
3

Saya tahu ini sudah terlalu tua, tetapi Anda dapat melihat http://phpthreadlib.sourceforge.net/

Ini mendukung komunikasi dua arah yang bersifat dua arah dan juga memiliki perlindungan untuk membunuh anak-anak (mencegah anak yatim).

Tidak ditandatangani
sumber
3

Anda dapat memiliki opsi:

  1. multi_curl
  2. Seseorang dapat menggunakan perintah sistem untuk hal yang sama
  3. Skenario ideal adalah, buat fungsi threading dalam bahasa C dan kompilasi / konfigurasikan dalam PHP. Sekarang fungsi itu akan menjadi fungsi PHP.
Manoj Donga
sumber
3

Kelas Thread tersedia sejak PECL pthreads ≥ 2.0.0.

Dhananjay Kashyap
sumber
1
dapatkah saya menjalankan utas melalui HTTP? sederhana: yourname.com/thread.php?
My Name
pThread sekarang dihentikan dari php 7.4 sebagai gantinya menggunakan paralel
Airy
3

Bagaimana dengan pcntl_fork?

lihat 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
    }

?>
Jarrod
sumber
2

pcntl_forktidak akan berfungsi di lingkungan server web jika telah mengaktifkan mode aman . Dalam hal ini, itu hanya akan berfungsi dalam versi PHP CLI.

Stilero
sumber
1

Jika Anda menggunakan server Linux, Anda dapat menggunakan

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

Jika Anda perlu melewati beberapa argumen

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

Di script.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();
Юрий Ярвинен
sumber
-1

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

Satu trik yang tidak dapat diandalkan, kotor, adalah menggunakan PHP untuk menjalankan aplikasi konsol, "tidak sama",

uname -a

dan cetak output dari perintah konsol itu ke output HTML untuk mengetahui versi yang tepat dari perangkat lunak server. Kemudian instal versi perangkat lunak yang sama persis ke instance VirtualBox, kompilasi / kumpulkan biner apa pun yang sepenuhnya mandiri, lebih disukai statis, yang diinginkan dan kemudian unggah ke server. Sejak saat itu dan seterusnya aplikasi PHP dapat menggunakan binari-binari tersebut dalam peran aplikasi konsol yang memiliki multi-threading yang tepat. Ini adalah solusi yang kotor, tidak dapat diandalkan, solusi untuk suatu situasi, ketika administrator server belum menginstal semua implementasi bahasa pemrograman yang diperlukan ke server. Hal yang harus diperhatikan adalah bahwa pada setiap permintaan aplikasi PHP menerima aplikasi konsol berakhir / 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 DI IKLAN dan jika eksekusi perintah konsol diizinkan dan mengunggah file non-malware diizinkan dan penyedia layanan memiliki hak untuk membunuh proses server apa pun setelah beberapa menit atau bahkan setelah 30 detik , maka administrator layanan hosting tidak memiliki argumen untuk membentuk keluhan yang tepat. Di Amerika Serikat dan Eropa Barat situasi / budaya sangat berbeda dan saya percaya bahwa ada peluang besar bahwa di AS dan / atau Eropa Barat penyedia layanan hosting akan menolak untuk melayani klien layanan hosting yang menggunakan trik yang dijelaskan di atas. Itu hanya tebakan saya, mengingat pengalaman pribadi saya dengan AS layanan hosting dan memberikan apa yang saya dengar dari orang lain tentang layanan hosting Eropa Barat. Pada saat menulis komentar saya saat ini (2018_09_01) saya tidak tahu apa-apa tentang norma-norma budaya penyedia layanan hosting Eropa Selatan, administrator jaringan Eropa Selatan.

Martin Vahi
sumber
-3

Mungkin saya melewatkan sesuatu tetapi exec tidak bekerja sebagai tidak sinkron untuk saya di lingkungan windows yang saya gunakan berikut di windows dan itu bekerja seperti pesona;)

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

pclose(popen("start /B ". $script_exec, "r"));
Mubashar
sumber
1
Untuk meretas multithreading di PHP Anda harus membuka beberapa pernyataan popen () (PHP tidak akan menunggu sampai selesai). Kemudian setelah setengah lusin terbuka Anda memanggil pclose () pada mereka (PHP akan menunggu di pclose () untuk menyelesaikan). Dalam kode Anda, Anda menutup setiap utas segera setelah membukanya sehingga kode Anda tidak akan berperilaku seperti multithreaded.
Kmeixner
-5

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

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

}

Ini akan menjalankan test_1.php dua kali secara bersamaan dan kedua proses akan berjalan di latar belakang secara bersamaan, sehingga dengan cara ini Anda dapat mencapai multithreading di php.

Orang ini melakukan pekerjaan yang sangat baik Multithreading di php

Pir Abdul
sumber
Juga, ini tidak ada hubungannya dengan MultiThreading. Ini adalah pemrosesan paralel. Hal yang sangat berbeda.
Digital Human
Menurut pendapat saya sebagai solusi, peretasan darurat, ide di balik solusi yang ditawarkan sangat tepat, tetapi saya kira orang yang berbeda dapat memiliki perang api tentang apa yang disebut "true multi-threading", karena ada perbedaan antara concurrency dan perangkat keras berbasis pemrosesan paralel, seperti yang dijelaskan di: youtube.com/watch?v=cN_DpYBzKso
Martin Vahi