Newsgroups: php.internals
Path: news.php.net
Xref: news.php.net php.internals:129401
Precedence: list
MIME-Version: 1.0
References: <CAMW7n8Dogjj2JFJBNArk-BfvOHRqHKMAFReXJAhDm2UPV1TF7A@mail.gmail.com>
 <CADK1yXKgkuKmOMB7KA9GNQMtpNw7ZgWcPEPE_Uhr_+8eReDCEA@mail.gmail.com>
 <CAMW7n8D+RGAFDY3oGnzaAabrhW9TOMeBgtvx4zCy3AoBUb5szA@mail.gmail.com>
 <CAEKnhAFsXpfZy8FQyA4Z9bNyNa26rCCn5GO=oQ274e1K2+GkAw@mail.gmail.com>
 <E4EE97C5-76EB-4C65-A3BE-7FFE27DD1500@rwec.co.uk> <383528143.397454.1763760932585@email.ionos.de>
 <CAMW7n8BjVM7SdM8Jn3dOmrXgngxycerZr9Cm4jeACnXaETQCWQ@mail.gmail.com>
 <691963327.399484.1763796022993@email.ionos.de> <CAMW7n8DnE_M3MOOfH_4x9DOZyQyT6FCbhBtU+6tuDD3Rw0vzbQ@mail.gmail.com>
 <1402906904.784903.1763811759896@email.ionos.de> <2015208655.784984.1763811978476@email.ionos.de>
 <CAMW7n8D0=6hEPpZpGe2SrYKqgFqsDkPAjHBP4g5K45bFPaiNdw@mail.gmail.com>
 <980296152.1071.1763813573083@email.ionos.de> <CAMW7n8DXA501uGOY3952y8YhAJDVRrPYEiuw+Wzc5=oEciLVZQ@mail.gmail.com>
 <92865666.4510.1763818506332@email.ionos.de> <CAMW7n8AycfX4NMfjJ+GzFsPqRaSae-t7Cm3H5z8apRzXUgaVZw@mail.gmail.com>
 <329450798.8037.1763822426377@email.ionos.de> <CAMW7n8DTt2S_RfcyshERixed=qqyFUPEvWp_MpgpW_CvH3urXQ@mail.gmail.com>
In-Reply-To: <CAMW7n8DTt2S_RfcyshERixed=qqyFUPEvWp_MpgpW_CvH3urXQ@mail.gmail.com>
Date: Sat, 22 Nov 2025 17:59:26 +0200
Message-ID: <CAMW7n8CUQxqh4_rTWQBcj+t17i5oW7x-V96FSkwZL85Z2pzrRw@mail.gmail.com>
Subject: Re: [PHP-DEV] [VOTE] True Async RFC 1.6
Cc: internals@lists.php.net
Content-Type: text/plain; charset="UTF-8"
From: edmond.ht@gmail.com (Edmond Dantes)

```php
use Async\spawn;
use Async\Channel;

function worker(Channel $tasks) {
    // Start a process for this coroutine
    $proc = proc_open("php worker.php", [
        ["pipe","r"],
        ["pipe","w"],
        ["pipe","w"]
    ], $pipes);

    $stdin  = $pipes[0];
    $stdout = $pipes[1];

    while (true) {
        // Receive a task (this suspends the coroutine)
        $task = $tasks->recv();

        // Write task to process (suspends while writing)
        fwrite($stdin, $task . "\n");

        // Read result (suspends while waiting for data)
        $result = fgets($stdout);
        ... make some else
    }
}

$tasks = new Channel();

// Start N workers
for ($i = 0; $i < 10; $i++) {
    spawn(worker(...), $tasks);
}

// Producer...
$tasks->push(...);
$tasks->push(...);
$tasks->push(...);

// Close Channel auto after leave function

```

Please look at this code.
There are three or five other ways to implement it. And most of them
would likely be worse in terms of reliability. Because in this example
there is almost no asynchronous code at all. Everything is sequential.
There is no synchronization. There is nothing. Just a channel and just
coroutines. That is all. And inside each coroutine the code is
synchronous.

And you do not even need any structural concurrency. The task is
solved because when the channel is destroyed, an exception is thrown
and the coroutines will terminate together with the rest of the code.

Of course, if you add automatic process restart, it becomes a bit more
complex, but the code is still synchronous. Which is very good.

Imagine a person who has never worked with async before. How hard
would it be for them to write this code?

---
Ed