Fibers (PHP 8.1)

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

Les Fibers sont une fonctionnalité de PHP 8.1 qui permet l'exécution de code interruptible. Contrairement aux fonctions classiques qui s'exécutent du début à la fin, une fiber peut s'interrompre en cours d'exécution et reprendre plus tard, tout en conservant son état entre les pauses.

Créez un fiber en passant un callable à la classe Fiber, puis démarrez-le 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. Appeler resume() poursuit l'exécution là où elle s'est arrêtée.

Les Fibers peuvent également transmettre des valeurs lors de la suspension et de la 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 Fibers sont le fondement des frameworks PHP asynchrones. Bien que vous ne les utilisiez pas directement dans la plupart des applications, les comprendre aide lors de l'utilisation de bibliothèques asynchrones qui gèrent des opérations concurrentes comme des requêtes HTTP ou des requêtes de base de données sans blocage.

Défi

Facile

Construisons un planificateur de tâches qui démontre comment les fibers peuvent mettre en pause et reprendre l'exécution tout en échangeant des données entre la fiber et le code principal. Vous allez créer un système où les tâches peuvent être interrompues, permettant à d'autres travaux de s'effectuer entre-temps.

Vous organiserez votre code sur deux fichiers :

TaskRunner.php — Créez une classe TaskRunner qui enveloppe les fonctionnalités de fiber pour l'exécution de tâches. La classe doit :
- Avoir une propriété privée pour stocker une instance de Fiber
- Accepter un nom de tâche (chaîne de caractères) dans son constructeur en utilisant la promotion de propriété de constructeur
- Avoir une méthode createTask(callable $task) qui crée une nouvelle Fiber avec le callable donné et la stocke
- Avoir une méthode start() qui démarre la fiber et retourne la valeur avec laquelle la fiber se suspend (ou la valeur de retour finale)
- Avoir une méthode continue(mixed $value) qui reprend la fiber avec la valeur donnée et retourne la valeur de suspension suivante (ou la valeur de retour finale)
- Avoir une méthode isFinished(): bool qui indique si la fiber 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 donné, 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 lors de sa reprise
3. Retourne "Completed: [received value]"
Démarrez la tâche et affichez ce qu'elle retourne lors de sa première suspension. Affichez ensuite "Processing..." pour montrer le travail effectué entre les pauses de la fiber. Enfin, continuez la fiber en lui passant le message d'entrée, et affichez le résultat final.

Ce défi montre comment les fibers permettent le multitâche coopératif — votre tâche se met en pause d'elle-même à un point opportun, le code principal effectue d'autres travaux, puis reprend la tâche avec de nouvelles données. La fiber conserve son état tout au long du processus, reprenant exactement là où elle s'était arrêtée.

Aide-mémoire

Les Fibers permettent l'exécution de code interruptible en PHP 8.1+. Contrairement aux fonctions classiques, une fiber peut s'interrompre en cours d'exécution et reprendre plus tard tout en conservant son état.

Créez une fiber en passant un callable à la classe Fiber et 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();

La fiber s'exécute jusqu'à Fiber::suspend(), puis le contrôle revient au code principal. Appelez resume() pour continuer l'exécution là où elle s'est arrêtée.

Les Fibers peuvent transmettre des valeurs lors de la suspension et de la reprise :

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

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

Méthodes clés :

start() — commence l'exécution de la fiber
Fiber::suspend($value) — suspend l'exécution et renvoie une valeur à l'appelant
resume($value) — continue l'exécution et transmet une valeur à la fiber
isTerminated() — vérifie si la fiber est terminé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. Se suspend d'abord avec la chaîne "Waiting for input"
// 2. Reçoit une valeur lors de la 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 effectué entre les pauses de la fibre

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

// TODO: Afficher le résultat final

?>