execution: P2079R10 Replaceability API (#1511)

- receiver_proxyクラス
- bulk_item_receiver_proxyクラス

Author: yohhoy

reference/execution/execution/parallel_scheduler.md

@@ -34,7 +34,7 @@ namespace std::execution {
 
 説明用の`sch2`を`parallel_scheduler`型のオブジェクトとしたとき、`BACKEND-OF(sch)`と`BACKEND-OF(sch2)`が同一オブジェクトを指す場合に限って、2つのオブジェクト`sch`と`sch2`は等しい。
 
-`rcvr`を[Receiver](receiver.md)としたとき、基底`B`を持つ`rcvr`のプロキシ(proxy for `rcvr` with base `B`)は下記を満たす`B`型の左辺値`r`となる。
+`rcvr`を[Receiver](receiver.md)としたとき、基底`B`を持つ`rcvr`のプロキシは下記を満たす`B`型の左辺値`r`となる。
 
 - `r.set_value()`は、[`set_value`](set_value.md)`(std::move(rcvr))`と同じ効果。
 - `r.set_error(e)`は、`e`を[`exception_ptr`](/reference/exception/exception_ptr.md)として、[`set_error`](set_error.md)`(std::move(rcvr), std::move(e))`と同じ効果。
@@ -43,22 +43,22 @@ namespace std::execution {
 プロキシ`r`に対する事前確保バックエンドストレージ(preallocated backend storage)は、[`span`](/reference/span/span.md)`<`[`byte`](/reference/cstddef/byte.md)`>`型のオブジェクト`s`であり、`r`に対して[`set_value`](set_value.md)／[`set_error`](set_error.md)／[`set_stopped`](set_stopped.md)いずれかが呼び出されるまで範囲`s`は有効かつ上書き可能である。
 
 呼び出し可能オブジェクト`f`と引数`arg`を持つ`rcvr`のバルクチャンク化プロキシ(bulk chunked proxy)は、基底
-[`system_context_replaceability::bulk_item_receiver_proxy`](system_context_replaceability/bulk_item_receiver_proxy.md.nolink)を持つ`rcvr`のプロキシ`r`であり、インデクス`i`, `j`に対する`r.execute(i, j)`は`f(i, j, args...)`と同じ効果を持つ。
+[`system_context_replaceability::bulk_item_receiver_proxy`](system_context_replaceability/bulk_item_receiver_proxy.md)を持つ`rcvr`のプロキシ`r`であり、インデクス`i`, `j`に対する`r.execute(i, j)`は`f(i, j, args...)`と同じ効果を持つ。
 
 呼び出し可能オブジェクト`f`と引数`arg`を持つ`rcvr`のバルク非チャンク化プロキシ(bulk unchunked proxy)は、基底
-[`system_context_replaceability::bulk_item_receiver_proxy`](system_context_replaceability/bulk_item_receiver_proxy.md.nolink)を持つ`rcvr`のプロキシ`r`であり、インデクス`i`に対する`r.execute(i, i + 1)`は`f(i, args...)`と同じ効果を持つ。
+[`system_context_replaceability::bulk_item_receiver_proxy`](system_context_replaceability/bulk_item_receiver_proxy.md)を持つ`rcvr`のプロキシ`r`であり、インデクス`i`に対する`r.execute(i, i + 1)`は`f(i, args...)`と同じ効果を持つ。
 
 
-### `schedule` ファクトリ
+### `schedule`アルゴリズム
 説明用の`b`を`BACKEND-OF(sch)`、`sndr`を[`schedule`](schedule.md)`(sch)`が返すオブジェクト、`rcvr`を[Receiver](receiver.md)とする。`rcvr`が`sndr`に[接続(connect)](connect.md)され、結果の[Operation State](operation_state.md)が[開始(start)](start.md)されたとき、
 
 - `sndr`が値完了するならば、[`b.schedule`](system_context_replaceability/parallel_scheduler_backend/schedule.md)`(r, s)`が呼ばれる。このとき、
-    - `r`は基底[`system_context_replaceability::receiver_proxy`](system_context_replaceability/receiver_proxy.md.nolink)を持つ`rcvr`のプロキシであり、かつ
+    - `r`は基底[`system_context_replaceability::receiver_proxy`](system_context_replaceability/receiver_proxy.md)を持つ`rcvr`のプロキシであり、かつ
     - `s`は`r`に対する事前確保バックエンドストレージである。
 - 他の全ての完了操作は、変更なしに転送される。
 
 
-### `bulk_chunked` アダプタ
+### `bulk_chunked`アルゴリズム
 `parallel_scheduler`は[`bulk_chunked`](bulk_chunked.md)アルゴリズムのカスタマイズ実装を提供する。[Receiver](receiver.md)`rcvr`が`bulk_chunked(sndr, pol, shape, f)`が返す[Sender](sender.md)に[接続(connect)](connect.md)され、結果の[Operation State](operation_state.md)が[開始(start)](start.md)されたとき、
 
 - `sndr`が値`vals`で値完了するならば、`args`を`vals`を指す左辺値式のパックとして、[`b.schedule_bulk_chunked`](system_context_replaceability/parallel_scheduler_backend/schedule_bulk_chunked.md)`(shape, r, s)`が呼ばれる。このとき、
@@ -67,7 +67,7 @@ namespace std::execution {
 - 他の全ての完了操作は、変更なしに転送される。
 
 
-### `bulk_unchunked` アダプタ
+### `bulk_unchunked`アルゴリズム
 `parallel_scheduler`は[`bulk_unchunked`](bulk_unchunked.md)アルゴリズムのカスタマイズ実装を提供する。[Receiver](receiver.md)`rcvr`が`bulk_unchunked(sndr, pol, shape, f)`が返す[Sender](sender.md)に[接続(connect)](connect.md)され、結果の[Operation State](operation_state.md)が[開始(start)](start.md)されたとき、
 
 - `sndr`が値`vals`で値完了するならば、`args`を`vals`を指す左辺値式のパックとして、[`b.schedule_bulk_unchunked`](system_context_replaceability/parallel_scheduler_backend/schedule_bulk_unchunked.md)`(shape, r, s)`が呼ばれる。このとき、

reference/execution/execution/system_context_replaceability.md

@@ -14,8 +14,8 @@ namespace std::execution::system_context_replaceability {
 
 | 名前 | 説明 | 対応バージョン |
 |------|------|----------------|
-| [`receiver_proxy`](system_context_replaceability/receiver_proxy.md.nolink) | バックエンド実装用のReceiverプロキシ (class) | C++26 |
-| [`bulk_item_receiver_proxy`](system_context_replaceability/bulk_item_receiver_proxy.md.nolink) | バックエンド実装用のバルク処理Receiverプロキシ (class) | C++26 |
+| [`receiver_proxy`](system_context_replaceability/receiver_proxy.md) | バックエンド実装用のReceiverプロキシ (class) | C++26 |
+| [`bulk_item_receiver_proxy`](system_context_replaceability/bulk_item_receiver_proxy.md) | バックエンド実装用のバルク処理Receiverプロキシ (class) | C++26 |
 | [`parallel_scheduler_backend`](system_context_replaceability/parallel_scheduler_backend.md) | 並列Schedulerバックエンド (class) | C++26 |
 | [`query_parallel_scheduler_backend`](system_context_replaceability/query_parallel_scheduler_backend.md) | 並列Schedulerバックエンドを問い合わせ (function) | C++26 |
 

reference/execution/execution/system_context_replaceability/bulk_item_receiver_proxy.md

@@ -0,0 +1,42 @@
+# bulk_item_receiver_proxy
+* execution[meta header]
+* class[meta id-type]
+* std::execution::system_context_replaceability[meta namespace]
+* cpp26[meta cpp]
+
+```cpp
+namespace std::execution::system_context_replaceability {
+  struct bulk_item_receiver_proxy : receiver_proxy { see below };
+}
+```
+* receiver_proxy[link receiver_proxy.md]
+
+## 概要
+`bulk_item_receiver_proxy`は、[`receiver_proxy`](receiver_proxy.md)から派生したクラス。
+[`bulk_chunked`](../bulk_chunked.md)および[`bulk_unchunked`](../bulk_unchunked.md)のカスタマイズで用いられ、異なる反復に対応する[`parallel_scheduler_backend`](parallel_scheduler_backend.md)実装から通知も受信する。
+
+
+## メンバ関数
+
+| 名前 | 説明 | 対応バージョン |
+|------|------|----------------|
+| `virtual void execute(size_t, size_t) noexcept = 0;` | 要素範囲の作業ハンドラ | C++26 |
+
+
+## バージョン
+### 言語
+- C++26
+
+### 処理系
+- [Clang](/implementation.md#clang): ??
+- [GCC](/implementation.md#gcc): ??
+- [ICC](/implementation.md#icc): ??
+- [Visual C++](/implementation.md#visual_cpp): ??
+
+
+## 関連項目
+- [`execution::parallel_scheduler`](../parallel_scheduler.md)
+
+
+## 参照
+- [P2079R10 Parallel scheduler](https://open-std.org/jtc1/sc22/wg21/docs/papers/2025/p2079r10.html)

reference/execution/execution/system_context_replaceability/parallel_scheduler_backend.md

@@ -11,7 +11,7 @@ namespace std::execution::system_context_replaceability {
 ```
 
 ## 概要
-[並列Scheduler](../parallel_scheduler.md)バックエンドのインタフェース（純粋仮想関数）を定義するクラス。
+`parallel_scheduler_backend`は、[並列Scheduler](../parallel_scheduler.md)バックエンド実装者向けのインタフェースを定義する。
 
 
 ## メンバ関数

reference/execution/execution/system_context_replaceability/parallel_scheduler_backend/schedule.md

@@ -8,7 +8,8 @@
 ```cpp
 virtual void schedule(receiver_proxy& r, span<byte> s) noexcept = 0;
 ```
-* receiver_proxy[link ../receiver_proxy.md.nolink]
+* receiver_proxy[link ../receiver_proxy.md]
+* span[link /reference/span/span.md]
 * byte[link /reference/cstddef/byte.md]
 
 ## 概要
@@ -23,9 +24,9 @@ virtual void schedule(receiver_proxy& r, span<byte> s) noexcept = 0;
 派生クラスでは、この関数を下記のように実装すべきである。
 
 - 下記いずれかの式が評価される
-    - エラーが発生せず作業が成功したとき、`r.set_value()`
-    - エラーが発生したとき、`eptr`を[`exception_ptr`](/reference/exception/exception_ptr.md)型のオブジェクトとして、`r.set_error(eptr)`
-    - 作業がキャンセルされたとき、`r.set_stopped()`
+    - エラーが発生せず作業が成功したとき、[`r.set_value()`](../receiver_proxy.md)
+    - エラーが発生したとき、`eptr`を[`exception_ptr`](/reference/exception/exception_ptr.md)型のオブジェクトとして、[`r.set_error`](../receiver_proxy.md)`(eptr)`
+    - 作業がキャンセルされたとき、[`r.set_stopped()`](../receiver_proxy.md)
 - 任意の`r.set_value()`呼び出しは、`*this`で表される実行コンテキストの実行エージェント上で発生する。
 
 

reference/execution/execution/system_context_replaceability/parallel_scheduler_backend/schedule_bulk_chunked.md

@@ -6,10 +6,12 @@
 * cpp26[meta cpp]
 
 ```cpp
-virtual void schedule_bulk_chunked(size_t n, bulk_item_receiver_proxy& r,
+virtual void schedule_bulk_chunked(size_t n,
+                                   bulk_item_receiver_proxy& r,
                                    span<byte> s) noexcept = 0;
 ```
-* bulk_item_receiver_proxy[link ../bulk_item_receiver_proxy.md.nolink]
+* bulk_item_receiver_proxy[link ../bulk_item_receiver_proxy.md]
+* span[link /reference/span/span.md]
 * byte[link /reference/cstddef/byte.md]
 
 ## 概要
@@ -24,12 +26,12 @@ virtual void schedule_bulk_chunked(size_t n, bulk_item_receiver_proxy& r,
 派生クラスでは、この関数を下記のように実装すべきである。
 
 - 下記いずれかの式が評価される
-    - エラーが発生せず作業が成功したとき、`r.set_value()`
-    - エラーが発生したとき、`eptr`を[`exception_ptr`](/reference/exception/exception_ptr.md)型のオブジェクトとして、`r.set_error(eptr)`
-    - 作業がキャンセルされたとき、`r.set_stopped()`
-- `r.execute(b, e)`が呼ばれたとき、`b`と`e`は範囲`[0, n)`内かつ`b < e`である
-- 範囲`[0, n)`の各`i`について、`i`が`[b, e)`の範囲内にある`r.execute(b, e)`の呼び出しが最大で1つだけ存在する。
-- `r.set_value()`が呼び出されたとき、`[0, n)`の各`i`に対して、`i`が`[b, e)`の範囲内となる`r.execute(b, e)`の呼び出しが正確に1つだけ存在する。
+    - エラーが発生せず作業が成功したとき、[`r.set_value()`](../receiver_proxy.md)
+    - エラーが発生したとき、`eptr`を[`exception_ptr`](/reference/exception/exception_ptr.md)型のオブジェクトとして、[`r.set_error`](../receiver_proxy.md)`(eptr)`
+    - 作業がキャンセルされたとき、[`r.set_stopped()`](../receiver_proxy.md)
+- [`r.execute`](../bulk_item_receiver_proxy.md)`(b, e)`が呼ばれたとき、`b`と`e`は範囲`[0, n)`内かつ`b < e`である
+- 範囲`[0, n)`の各`i`について、`i`が`[b, e)`の範囲内にある[`r.execute`](../bulk_item_receiver_proxy.md)`(b, e)`の呼び出しが最大で1つだけ存在する。
+- `r.set_value()`が呼び出されたとき、`[0, n)`の各`i`に対して、`i`が`[b, e)`の範囲内となる[`r.execute`](../bulk_item_receiver_proxy.md)`(b, e)`の呼び出しが正確に1つだけ存在する。
 - `r`上での全ての`execute`呼び出しは、`r`上での`set_value`／`set_error`／`set_stopped`いずれかの呼び出しよりも前に発生する。
 - `r`上での全ての`execute`および`set_value`呼び出しは、`*this`で表される実行コンテキストの実行エージェント上で行われる。
 

reference/execution/execution/system_context_replaceability/parallel_scheduler_backend/schedule_bulk_unchunked.md

@@ -6,10 +6,12 @@
 * cpp26[meta cpp]
 
 ```cpp
-virtual void schedule_bulk_unchunked(size_t n, bulk_item_receiver_proxy& r,
+virtual void schedule_bulk_unchunked(size_t n,
+                                     bulk_item_receiver_proxy& r,
                                      span<byte> s) noexcept = 0;
 ```
-* bulk_item_receiver_proxy[link ../bulk_item_receiver_proxy.md.nolink]
+* bulk_item_receiver_proxy[link ../bulk_item_receiver_proxy.md]
+* span[link /reference/span/span.md]
 * byte[link /reference/cstddef/byte.md]
 
 ## 概要
@@ -24,11 +26,11 @@ virtual void schedule_bulk_unchunked(size_t n, bulk_item_receiver_proxy& r,
 派生クラスでは、この関数を下記のように実装すべきである。
 
 - 下記いずれかの式が評価される
-    - エラーが発生せず作業が成功したとき、`r.set_value()`
-    - エラーが発生したとき、`eptr`を[`exception_ptr`](/reference/exception/exception_ptr.md)型のオブジェクトとして、`r.set_error(eptr)`
-    - 作業がキャンセルされたとき、`r.set_stopped()`
-- `r.execute(b, e)`が呼ばれたとき、`b`は範囲`[0, n)`内かつ`e`は`b + 1`に等しい。`[0, n)`の各`i`について、`r.execute(i, i + 1)`の呼び出しが最大で1つだけ存在する。
-- `r.set_value()`が呼び出されたとき、`[0, n)`の各`i`に対して、`r.execute(i, i + 1)`の呼び出しが正確に1つだけ存在する。
+    - エラーが発生せず作業が成功したとき、[`r.set_value()`](../receiver_proxy.md)
+    - エラーが発生したとき、`eptr`を[`exception_ptr`](/reference/exception/exception_ptr.md)型のオブジェクトとして、[`r.set_error`](../receiver_proxy.md)`(eptr)`
+    - 作業がキャンセルされたとき、[`r.set_stopped()`](../receiver_proxy.md)
+- [`r.execute`](../bulk_item_receiver_proxy.md)`(b, e)`が呼ばれたとき、`b`は範囲`[0, n)`内かつ`e`は`b + 1`に等しい。`[0, n)`の各`i`について、[`r.execute`](../bulk_item_receiver_proxy.md)`(i, i + 1)`の呼び出しが最大で1つだけ存在する。
+- `r.set_value()`が呼び出されたとき、`[0, n)`の各`i`に対して、[`r.execute`](../bulk_item_receiver_proxy.md)`(i, i + 1)`の呼び出しが正確に1つだけ存在する。
 - `r`上での全ての`execute`呼び出しは、`r`上での`set_value`／`set_error`／`set_stopped`いずれかの呼び出しよりも前に発生する。
 - `r`上での全ての`execute`および`set_value`呼び出しは、`*this`で表される実行コンテキストの実行エージェント上で行われる。
 

reference/execution/execution/system_context_replaceability/receiver_proxy.md

@@ -0,0 +1,44 @@
+# receiver_proxy
+* execution[meta header]
+* class[meta id-type]
+* std::execution::system_context_replaceability[meta namespace]
+* cpp26[meta cpp]
+
+```cpp
+namespace std::execution::system_context_replaceability {
+  struct receiver_proxy;
+}
+```
+
+## 概要
+`receiver_proxy`は、[`parallel_scheduler_backend`](parallel_scheduler_backend.md)実装から完了操作のトリガー通知を受け取る[`Receiver`](../receiver.md)を表現する。
+
+
+## メンバ関数
+
+| 名前 | 説明 | 対応バージョン |
+|------|------|----------------|
+| `virtual ~receiver_proxy() = default;` | デストラクタ | C++26 |
+| `virtual void set_value() noexcept = 0;` | 値完了ハンドラ | C++26 |
+| `virtual void set_error(exception_ptr) noexcept = 0;` | エラー完了ハンドラ | C++26 |
+| `virtual void set_stopped() noexcept = 0;` | 停止完了ハンドラ | C++26 |
+| [`try_query`](receiver_proxy/try_query.md) | クエリオブジェクト問い合わせ | C++26 |
+
+
+## バージョン
+### 言語
+- C++26
+
+### 処理系
+- [Clang](/implementation.md#clang): ??
+- [GCC](/implementation.md#gcc): ??
+- [ICC](/implementation.md#icc): ??
+- [Visual C++](/implementation.md#visual_cpp): ??
+
+
+## 関連項目
+- [`execution::parallel_scheduler`](../parallel_scheduler.md)
+
+
+## 参照
+- [P2079R10 Parallel scheduler](https://open-std.org/jtc1/sc22/wg21/docs/papers/2025/p2079r10.html)

reference/execution/execution/system_context_replaceability/receiver_proxy/try_query.md

@@ -0,0 +1,57 @@
+# try_query
+* execution[meta header]
+* std::execution::system_context_replaceability[meta namespace]
+* receiver_proxy[meta class]
+* function template[meta id-type]
+* cpp26[meta cpp]
+
+```cpp
+template<class P, class-type Query>
+optional<P> try_query(Query q) noexcept;
+```
+* class-type[link ../../../class-type.md]
+* optional[link /reference/optional/optional.md]
+
+## 概要
+[`parallel_scheduler`](../../parallel_scheduler.md)バックエンド実装側から[Receiver](../../receiver.md)環境にアクセスするための補助関数。
+
+
+## 適格要件
+`P`はcv修飾された非配列オブジェクト型。
+
+
+## 戻り値
+説明用の`env`を`*this`が表現する[Receiver](../../receiver.md)の環境とする。
+下記を満たす場合は[`nullopt`](/reference/optional/nullopt_t.md)を返す。そうでなければ、`q(env)`を返す。
+
+- `Query`が実装定義のサポートされたクエリ集合のメンバではない、または
+- `P`が実装定義のサポートされた`Query`の結果型集合のメンバではない、または
+- 式`q(env)`が適格でないか、cv修飾された`P`型を持たない。
+
+
+## 例外
+投げない
+
+
+## 備考
+[`get_stop_token_t`](../../../get_stop_token.md)は実装定義のサポートされたクエリ集合に含まれ、[`inplace_stop_token`](/reference/stop_token/inplace_stop_token.md)は`get_stop_token_t`の実装定義のサポートされた結果型集合のメンバである。
+
+
+## バージョン
+### 言語
+- C++26
+
+### 処理系
+- [Clang](/implementation.md#clang): ??
+- [GCC](/implementation.md#gcc): ??
+- [ICC](/implementation.md#icc): ??
+- [Visual C++](/implementation.md#visual_cpp): ??
+
+
+## 関連項目
+- [`execution::parallel_scheduler`](../../parallel_scheduler.md)
+- [`execution::parallel_scheduler_backend::parallel_scheduler_backend`](../parallel_scheduler_backend.md)
+
+
+## 参照
+- [P2079R10 Parallel scheduler](https://open-std.org/jtc1/sc22/wg21/docs/papers/2025/p2079r10.html)