La tâche swoole va-t-elle bloquer ?

Si vous avez lu attentivement la documentation de la tâche swoole, vous avez dû remarquer cette phrase

Le nombre d'opérations de tâche doit être inférieur à la vitesse de traitement d'onTask . Si Si la capacité de livraison dépasse la capacité de traitement, la tâche remplira la zone de cache, provoquant le blocage du processus de travail.

Le processus de travail ne pourra pas recevoir de nouvelles demandes                                                                                                                                                              pour le didacticiel vidéo de swoole Le service ne fonctionne pas, ce qui entraîne des problèmes.

J'ai déjà utilisé une tâche pour envoyer le journal des liens du service. Un bug s'est produit dans le service qui a reçu le journal, provoquant le blocage de la tâche d'envoi du journal puis de service de gg. ça, j'ai fait une vague d'optimisations à la tâche.

L'idée est d'utiliser le canal swoole et le processus utilisateur swoole pour implémenter un ensemble de tâches.

Utilisez le canal pour recevoir des données, puis consommez les données dans le processus utilisateur. Si le canal est plein, cela entraînera uniquement l'échec des données push et ne provoquera pas de blocage car il s'agit d'un lien. log, la perte est autorisée, donc cette solution ne pose absolument aucun problème.

Le pseudocode de la stratégie de consommation du canal dans le processus utilisateur swoole est le suivant

$sleepTime = 5;
$maxSleepTime = 100;
while (true) {
    $task = $chan->pop();
    if ($task === false) {
        $sleepTime = $sleepTime + 5;
        if ($sleepTime > $maxSleepTime) {
            $sleepTime = $maxSleepTime;
        }
        usleep($sleepTime * 1000);
        continue;
    }
    $sleepTime = 0;
    // 处理数据
}

Si les données du canal sont consommées, une boucle infinie est utilisée pour traiter les données, car pendant le traitement des données, il y a d'autres opérations, donc cela ne prend pas beaucoup de CPU.

Si les données ne peuvent pas être consommées, mettez en veille pendant 5 ms. Le temps de veille est accumulé en séquence jusqu'à ce qu'il atteigne la valeur maximale de 100 ms pour atteindre un équilibre entre l'utilisation du processeur et le traitement des données en temps réel. Le point peut être déterminé en fonction de votre propre entreprise. Ajustement des besoins.

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!