Multithreading en PHP et comment l'implémenter

Le multithreading fait référence à l'exécution de plusieurs threads (flux d'exécution de programme) en même temps dans une application et peut effectuer plusieurs tâches en même temps. En PHP, le multithreading est largement utilisé dans des scénarios nécessitant l'exécution simultanée de plusieurs tâches, telles que les calculs Big Data, l'accès simultané, etc. Cet article présentera le multithreading en PHP et comment l'implémenter.

1. Principe d'implémentation multi-thread PHP

Avant de vraiment comprendre la méthode d'implémentation multi-thread PHP, il y a un concept qui doit être compris, et c'est la relation entre les processus et les threads. Un processus fait référence à une instance de programme en cours d'exécution. Chaque processus possède son propre espace mémoire et ses propres ressources, et les processus sont indépendants les uns des autres. Un thread est une unité exécutable au sein d'un processus. Un processus peut contenir plusieurs threads et partager les ressources du processus. L'avantage du multithread par rapport au multiprocessus est que la commutation entre les threads est plus rapide que la commutation entre les processus et que la surcharge de ressources est moindre. Elle convient aux scénarios tels que l'accès simultané qui nécessitent l'exécution de plusieurs tâches en même temps.

En PHP, pour implémenter le multi-threading, vous devez utiliser une extension appelée bibliothèque "PCNTL". Cette extension fournit un ensemble de fonctions capables de contrôler les processus et la gestion des signaux, permettant une programmation multi-processus et multi-thread.

2. Méthode d'implémentation du multi-threading PHP

1. Utilisez la fonction pcntl_fork() pour créer un processus enfant

Utilisez la fonction pcntl_fork() en PHP pour créer un processus enfant et copier le processus actuel en deux processus, l'un est le processus parent, l'autre est un processus enfant. Le processus parent et le processus enfant sont deux processus indépendants, mais ils partagent certaines ressources. Cette fonctionnalité peut être utilisée pour implémenter le multi-threading.

Ce qui suit est un exemple, créant 5 sous-processus, chaque sous-processus effectue des tâches différentes :

<?php
$workers = 5;

for ($i = 0; $i < $workers; $i++) {
    $pid = pcntl_fork();
    if ($pid === -1) {
        die('Could not fork');
    } elseif ($pid) {
        // 父进程继续执行
    } else {
        // 子进程执行任务
        sleep(5);
        exit(0);
    }
}

// 父进程等待所有子进程结束
while (pcntl_waitpid(0, $status) != -1) {
    $status = pcntl_wexitstatus($status);
    echo "Child $status completed
";
}
?>

2 Utilisez la fonction pcntl_signal() pour implémenter le traitement du signal

En multi-threading, afin d'éviter les conflits entre. différents threads, vous devez utiliser des mécanismes de gestion des signaux pour gérer les problèmes de synchronisation dans plusieurs threads.

Utilisez la fonction pcntl_signal() en PHP pour définir la méthode de traitement du signal. Voici un exemple de création de 5 processus enfants, chaque processus enfant effectue des tâches différentes. Lorsque tous les processus enfants auront terminé leurs tâches, le processus parent continuera à s'exécuter :

<?php
$workers = 5;
$jobs = [];

// 子进程任务
function doJob($job) {
    echo "Worker $job start
";
    sleep(5);
    echo "Worker $job completed
";
}

// 信号处理函数
function sig_handler($signo) {
    global $jobs;
    switch ($signo) {
        case SIGCHLD:
            // 检查所有子进程是否都已经结束
            while (($pid = pcntl_waitpid(-1, $status, WNOHANG)) > 0) {
                $jobs--;
            }
            break;
    }
}

// 安装信号处理器
pcntl_signal(SIGCHLD, "sig_handler");

// 创建子进程
for ($i = 0; $i < $workers; $i++) {
    $pid = pcntl_fork();
    if ($pid == -1) {
        die('Could not fork');
    } elseif ($pid == 0) {
        // 子进程执行任务
        doJob($i);
        exit(0);
    } else {
        // 父进程继续执行
        $jobs++;
    }
}

// 父进程等待所有子进程结束
while ($jobs > 0) {
    sleep(1);
}

// 所有子进程都已完成任务
echo "All workers completed
";
?>

Ce qui précède est la méthode d'implémentation du multi-threading en PHP. , qui peut être basé sur les besoins réels. Faites une sélection.

3.Résumé

La méthode d'implémentation multithread en PHP repose principalement sur l'extension de la bibliothèque "PCNTL". Utilisez la fonction pcntl_fork() pour créer un sous-processus, et utilisez la fonction pcntl_signal() pour implémenter le signal. traitement. Dans la programmation multi-thread, vous devez faire attention. Les problèmes de synchronisation nécessitent une synchronisation entre différents threads pour éviter les conflits.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!