Newsgroups: php.internals
Path: news.php.net
Xref: news.php.net php.internals:126692
Precedence: bulk
MIME-Version: 1.0
References: <CAMW7n8AJckEDzhGv9BdjNhq8zAdCqb4HsVr56vGi+izw50X6Dg@mail.gmail.com>
 <CAMW7n8CAbKRY9RZsJNSnehKVv8NNGtygocxc+zHBS4h9iRyUGA@mail.gmail.com>
 <1b6a5b3b-be9b-4e46-9cc6-b8b7f57b8494@app.fastmail.com> <CAMW7n8AumA6bYZ+7+c3rAEeYj0=35wgmohRbrJbH=fc=Ra0FJg@mail.gmail.com>
 <e65708a0-5130-4726-b405-e3185562d770@rwec.co.uk> <def2620e-9a99-4a6f-b414-3c9f74232f5c@app.fastmail.com>
 <E273F908-DE5A-411B-BAA5-D72A04310EAA@rwec.co.uk>
In-Reply-To: <E273F908-DE5A-411B-BAA5-D72A04310EAA@rwec.co.uk>
Date: Mon, 10 Mar 2025 13:36:50 +0200
Message-ID: <CAMW7n8CE0T1Tef549B+JKcZ9tHswmOteprRzYm3DbC8Skhux2g@mail.gmail.com>
Subject: Re: [PHP-DEV] Re: PHP True Async RFC
To: "Rowan Tommins [IMSoP]" <imsop.php@rwec.co.uk>
Cc: internals@lists.php.net
Content-Type: multipart/alternative; boundary="0000000000000aeead062ffb64b4"
From: edmond.ht@gmail.com (Edmond Dantes)

--0000000000000aeead062ffb64b4
Content-Type: text/plain; charset="UTF-8"
Content-Transfer-Encoding: quoted-printable

>function par_map(iterable $it, callable $c) {
>  $result =3D [];
>  async {
>    foreach ($it as $val) {
>      $result[] =3D $c($val);
>    }
>  }
>return $result;
>}

If the assumption is that each call can be asynchronous and all elements
need to be processed, the only proper tool is a concurrent iterator.
Manually using a foreach loop is not the best idea because the iterator
does not necessarily create a coroutine for each iteration.
And, of course, such an iterator should have a getFuture method that allows
waiting for the result.

Yes, Kotlin has an explicit blocking Scope, but I don=E2=80=99t see much ne=
ed for
it. So far, all the cases we=E2=80=99re considering fit neatly into a frame=
work:

   1. I want to launch a coroutine and wait: await spawn
   2. I want to launch a coroutine and not wait: spawn
   3. I want to launch a group of coroutines and wait: await CoroutineScope
   4. I want to launch a group of coroutines and not wait: spawn
   5. I want a concurrent iteration: special iterator.

What else are we missing?

--0000000000000aeead062ffb64b4
Content-Type: text/html; charset="UTF-8"
Content-Transfer-Encoding: quoted-printable

<div dir=3D"ltr">&gt;function par_map(iterable $it, callable $c) {<br>&gt;=
=C2=A0 $result =3D [];<br>&gt;=C2=A0 async {<br>&gt;=C2=A0 =C2=A0 foreach (=
$it as $val) {<br>&gt;=C2=A0 =C2=A0 =C2=A0 $result[] =3D $c($val);<br>&gt;=
=C2=A0 =C2=A0 }<br>&gt;=C2=A0 }<br>&gt;return $result;<br>&gt;}<br><div><br=
></div><div>If the assumption is that each call can be asynchronous and all=
 elements need to be processed, the only proper tool is a concurrent iterat=
or.=C2=A0</div><div>Manually using a <code>foreach</code> loop is not the b=
est idea because the iterator does not necessarily create a coroutine for e=
ach iteration.<br>
And, of course, such an iterator should have a <code>getFuture</code> metho=
d that allows waiting for the result.</div><div><br></div><div><p>Yes, Kotl=
in has an explicit blocking Scope, but I don=E2=80=99t see much need for it=
. So far, all the cases we=E2=80=99re considering fit neatly into a framewo=
rk:</p>
<ol>
<li>I want to launch a coroutine and wait: <code>await spawn</code></li>
<li>I want to launch a coroutine and not wait: <code>spawn</code></li>
<li>I want to launch a group of coroutines and wait: <code>await CoroutineS=
cope</code></li>
<li>I want to launch a group of coroutines and not wait: <code>spawn</code>=
</li>
<li>I want a concurrent iteration: special iterator.</li>
</ol>
<p>What else are we missing?</p></div></div>

--0000000000000aeead062ffb64b4--