Hacktoberfest 2026: le issue che i maintainer hanno segnato per ottobre, aperte e adatte ai principianti. Sfoglia le issue Hacktoberfest

[question] how do we `bulk` a batch of `senders` ?

Aperta
  • Qualcosa non va?
#1,614 1 commento 1 reazione 0 assegnatari Vedi su GitHub

I maintainer di solito rispondono entro 1 giorno

Nessuno ha ancora preso questa issue.

Valutazione

Difficoltà
5/5
Tempo stimato
Più di una settimana
Idoneità per principianti
25/100
Tipo di issue
Funzionalità
Chiarezza
Abbastanza chiara
Stato di attività
Ferma
Stack tecnologico
cpp
Ambito
backend-api-design

Direzione di ricerca

Non vengono nominati file sorgente né test. Inizia leggendo la documentazione esistente e gli entry point di bulk, when_all e sync_wait per determinare come vengono composte le operazioni che restituiscono sender; il lavoro è completo quando viene documentato se il comportamento richiesto è già supportato oppure, in caso contrario, viene definito un problema di API/design circoscritto.

Scritto dal modello di indicizzazione a partire dal testo della issue.

Descrizione

Suppose we have an async operation:

stdexec::sender auto tcp::socket::async_connect(endpoint);

Now we try to connect a batch of endpoints, and wait for all/any of them.

stdexec::sender auto task_1 = socket_1.async_connect("127.0.0.1:1");
stdexec::sender auto task_2 = socket_2.async_connect("127.0.0.1:2");
stdexec::sender auto task_3 = socket_3.async_connect("127.0.0.1:3");
/* ... */
stdexec::sender auto task_65535 = socket_65535.async_connect("127.0.0.1:65535");
stdexec::sync_wait(stdexec::when_all(task_1, task_2, task_3, /*...*/, task_65535));

The functions above are all senders instead of synchronous functions (that is, submit task and later callback). Although we can bulk synchronous functions using stdexec::bulk(policy, shape, sync_func), I wonder: is there a function that we can stdexec::/*bulk_what*/(policy, shape, func_who_returns_sender)? I tried hard to read the docs but sadly could not find it.

auto sockets = std::vector<tcp::socket>(65535);
stdexec::sync_wait(stdexec::/*let_bulk_or_some_name_else?*/(
    stdexec::par,
    65535,
    [&] { return sockets[i].async_connect(std::format("127.0.0.1:{}", i); }
)

Thank you!

Lingua principale
C++
Stelle
2.4k
Fork
274
Merge medio
1g 13h
PR unite (30g)
38

Preparare l'ambiente

Questo progetto non fornisce container di sviluppo, Dockerfile né guida per i contributori, quindi l'ambiente è a tuo carico: parti dal suo README e consulta la nostra guida al primo contributo per i passaggi generali.

Come iniziare

  1. Leggi tutta la issue e poi la guida ai contributi del progetto.
  2. Commenta sulla issue per dire che te ne occupi tu — evita che due persone facciano lo stesso lavoro.
  3. Fai un fork del repository e lavora su un branch.
  4. Apri una pull request che faccia riferimento al numero della issue.

Altre issue di NVIDIA/stdexec

Tutte le issue di NVIDIA/stdexec

Issue simili

Altre issue su C++

Ricevi le nuove issue nella tua casella

Un breve riepilogo di issue GitHub adatte ai principianti.