Fibres (PHP 8.1)

Fait partie de la section Programmation Orientée Objet du Journey PHP de Coddy. Leçon 60 sur 91.

Les fibres sont une fonctionnalité de PHP 8.1 qui permet une exécution de code interruptible. Contrairement aux fonctions ordinaires qui s’exécutent du début à la fin, une fibre peut se mettre en pause en cours d’exécution et reprendre plus tard, en conservant son état entre les pauses.

Créez une fibre en transmettant un appelable à la classe Fiber, puis démarrez-la avec start() :

<?php
$fiber = new Fiber(function(): void {
    echo "Step 1\n";
    Fiber::suspend();
    echo "Step 2\n";
});

$fiber->start();
echo "Between steps\n";
$fiber->resume();

Sortie :

Step 1
Between steps
Step 2

La fibre s’exécute jusqu’à ce qu’elle atteigne Fiber::suspend(), puis le contrôle revient au code principal. L’appel de resume() reprend l’exécution là où elle s’était interrompue.

Les fibers peuvent également transmettre des valeurs lors de leur suspension et de leur reprise :

<?php
$fiber = new Fiber(function(): string {
    $value = Fiber::suspend("paused");
    return "Received: $value";
});

$suspended = $fiber->start();
echo "$suspended\n";

$result = $fiber->resume("hello");
echo $result;

Sortie :

paused
Received: hello

Les fibres sont le fondement des frameworks PHP asynchrones. Bien que tu ne les utilises pas directement dans la plupart des applications, les comprendre t'aide à travailler avec des bibliothèques asynchrones qui gèrent des opérations concurrentes comme les requêtes HTTP ou les requêtes de base de données sans blocage.

Défi

Facile

Construisons un planificateur de tâches qui montre comment les fibers peuvent mettre en pause et reprendre l’exécution tout en transmettant des données entre la fiber et le code principal. Vous allez créer un système dans lequel les tâches peuvent être interrompues, permettant à d’autres opérations de se dérouler entre-temps.

Vous organiserez votre code sur deux fichiers :

TaskRunner.php : créez une classe TaskRunner qui encapsule les fonctionnalités des fibers pour exécuter des tâches. La classe doit :
- Posséder une propriété privée pour stocker une instance de Fiber
- Accepter un nom de tâche (chaîne) dans son constructeur à l’aide de la promotion du constructeur
- Posséder une méthode createTask(callable $task) qui crée une nouvelle Fiber avec le callable fourni et la stocke
- Posséder une méthode start() qui démarre la fiber et renvoie la valeur avec laquelle la fiber se suspend (ou la valeur de retour finale)
- Posséder une méthode continue(mixed $value) qui reprend la fiber avec la valeur fournie et renvoie la prochaine valeur suspendue (ou la valeur de retour finale)
- Posséder une méthode isFinished(): bool qui renvoie si la fiber s’est terminée
main.php : incluez le fichier TaskRunner. Vous recevrez deux entrées : un nom de tâche et un message à envoyer à la fiber.
Créez un TaskRunner avec le nom de tâche fourni, puis utilisez createTask() pour définir une tâche qui :
1. Se suspend d’abord avec la chaîne "Waiting for input"
2. Reçoit une valeur lorsqu’elle reprend
3. Renvoie "Completed: [received value]"
Démarrez la tâche et affichez ce qu’elle renvoie lorsqu’elle se suspend pour la première fois. Affichez ensuite "Processing..." pour montrer qu’un traitement a lieu entre les pauses de la fiber. Enfin, reprenez la fiber en lui transmettant le message d’entrée, puis affichez le résultat final.

Ce défi montre comment les fibers permettent le multitâche coopératif. Votre tâche se met elle-même en pause à un moment approprié, le code principal effectue d’autres opérations, puis reprend la tâche avec de nouvelles données. La fiber conserve son état tout au long de l’exécution et reprend exactement là où elle s’était arrêtée.

Essayez vous-même

<?php

require_once 'TaskRunner.php';

// Lire les entrées
$taskName = trim(fgets(STDIN));
$message = trim(fgets(STDIN));

// TODO: Créer un TaskRunner avec le nom de tâche donné

// TODO: Utiliser createTask() pour définir une tâche qui :
// 1. First suspends with the string "Waiting for input"
// 2. Reçoit une valeur lorsqu'elle est reprise
// 3. Retourne "Completed: [received value]"

// TODO: Démarrer la tâche et afficher ce qu'elle retourne lors de sa première suspension

// TODO: Afficher "Processing..." pour montrer le travail en cours entre les pauses de fiber

// TODO: Continuer la fiber en passant l'entrée message

// TODO: Afficher le résultat final

?>