Construct from a pool, receiver, shape, and function. Allocates O(min(shape, available_parallelism())) memory.
| 1457 | //! Construct from a pool, receiver, shape, and function. |
| 1458 | //! Allocates O(min(shape, available_parallelism())) memory. |
| 1459 | _bulk_shared_state(_static_thread_pool& pool, Receiver rcvr, Shape shape, Fun fun) |
| 1460 | : pool_{pool} |
| 1461 | , rcvr_{static_cast<Receiver&&>(rcvr)} |
| 1462 | , shape_{shape} |
| 1463 | , fun_{fun} |
| 1464 | , thread_with_exception_{num_agents_required()} |
| 1465 | , tasks_{num_agents_required(), {this}} |
| 1466 | {} |
| 1467 | }; |
| 1468 | |
| 1469 | //! A customized receiver to allow parallel execution of `STDEXEC::bulk` operations: |
nothing calls this directly
no test coverage detected