Entrevista técnica de C++26: ¿Cómo implementar una canalización multiejecutor segura ante cancelaciones?

Planteamiento y aplicabilidad

Un servicio debe componer la lectura, la transformación y la agregación en una canalización asíncrona. Quien realiza la llamada puede cancelar por tiempo de espera agotado, desconexión o presión sobre los recursos; cada etapa puede fallar mientras otro trabajo ya se encuentra en ejecución. Utilice el modelo sender/receiver de std::execution de C++26 para explicar la planificación, las señales de finalización, el ciclo de vida y las rutas de alternativa.

Esto evalúa los límites de una abstracción de concurrencia, no la memorización de la sintaxis de una biblioteca específica. La biblioteca estándar de control de ejecución separa el grafo de trabajo de un sender del manejo de finalización del receiver y utiliza un estado de operación para el estado asíncrono conectado. Una respuesta sólida establece la cancelación, la semántica de errores y la limpieza como contratos explícitos.

Qué evalúa el entrevistador

• Distinguir entre un sender perezoso (lazy), un estado de operación conectado y la ejecución real en start.
• Representar los recursos de ejecución con ejecutores (schedulers) en lugar de crear subprocesos ad hoc en el código de negocio.
• Manejar set_value, set_error y set_stopped por separado en lugar de disfrazar la cancelación como una excepción.
• Propagar solicitudes de detención a través de cada etapa y prevenir nuevos efectos secundarios tras la detención.
• Explicar la contrapresión, los límites, la seguridad ante excepciones y la agregación para el trabajo paralelo.
• Proporcionar detección de capacidades, una capa de compatibilidad y pruebas consistentes cuando la biblioteca estándar no esté disponible.

Aclaraciones a solicitar primero

1. ¿La lectura se realiza desde un archivo local, una solicitud de red o un cursor de base de datos? ¿Las etapas son repetibles o generan efectos secundarios externos?
2. ¿La cancelación implica detenerse de inmediato, detenerse tras una llamada ininterrumpible o revertir los resultados confirmados?
3. ¿Cuáles son los límites de paralelismo, memoria, tiempo de espera por elemento y plazo general?
4. ¿La agregación debe preservar el orden de entrada, resultados estables de punto flotante o resultados parciales visibles?
5. ¿El compilador y la biblioteca de destino implementan la ejecución de C++26 o solo una implementación experimental?

Una respuesta de 30 segundos

Definiría un contrato de finalización con canales de valor, error y detención (stopped). La cancelación evita el trabajo que no ha comenzado y permite que las etapas interrumpibles respondan rápidamente. Cada sender se mantiene perezoso; la conexión crea un estado de operación y start inicia la ejecución. Los ejecutores explícitos gestionan los recursos de ejecución, mientras que los límites de paralelismo y de cola protegen la memoria. El agregador define las reglas de ordenamiento y de resultados parciales. La detección de capacidades selecciona la implementación estándar, una biblioteca de compatibilidad o una ruta escalar síncrona, con pruebas compartidas para cancelación, errores y resultados.

Análisis detallado paso a paso

1. Dibujar el grafo de trabajo perezoso

Conecte un sender de lectura a un sender de transformación y luego a un sender de agregación. then pasa los valores producidos al siguiente nodo, let_value puede crear otra operación asíncrona a partir de un resultado y when_all representa ramas paralelas. La composición construye un grafo; no debe realizar E/S durante la construcción.

2. Definir la conexión y el ciclo de vida

connect entre un sender y un receiver crea un estado de operación; la ejecución solo se permite después de start. La dirección del estado de operación debe permanecer válida hasta que se complete la operación asíncrona, por lo que no puede residir en un marco de pila que esté a punto de retornar. Un contexto de solicitud o un ámbito asíncrono debe poseerlo y liberar los recursos en las rutas de valor, error y detención.

3. Asignar recursos a los ejecutores

Un ejecutor (scheduler) es un identificador liviano a un recurso de ejecución. Coloque la lectura en un recurso de E/S y la transformación de CPU en un recurso paralelo acotado; use on, starts_on o continues_on para expresar los límites de cada etapa. No cree un subproceso por elemento. Limite el paralelismo, la longitud de la cola y el tamaño del lote para controlar la memoria y el cambio de contexto.

4. Propagar stopped, error y value

La finalización por valor pasa a la siguiente etapa, los errores pasan al manejo unificado de errores y la detención pasa al manejo de cancelación. El token de detención (stop token) del entorno de un receiver es un punto de observación de cancelación. Las llamadas al sistema bloqueantes necesitan una interfaz interrumpible o un tiempo de espera acotado; de lo contrario, solo pueden responder tras retornar. La cancelación no es una reversión: una vez que ocurrió una escritura externa, use una clave de idempotencia, compensación o un límite irreversible explícito.

5. Un esquema de composición mínimo

El código muestra la estructura del grafo; los senders reales de lectura y del grupo de subprocesos son provistos por el proyecto.

using namespace std::execution;

auto pipeline = read_sender()
  | let_value([](Batch batch) {
      return bulk_transform(batch, get_parallel_scheduler());
    })
  | then([](Transformed value) { return summarize(value); })
  | upon_error([](std::exception_ptr error) { record_failure(error); })
  | upon_stopped([] { record_cancellation(); });

auto state = connect(std::move(pipeline), receiver);
start(state);

El receiver debe pertenecer a un ámbito de solicitud activo que proporcione un stop token en su entorno. El código de producción también debe registrar la etapa, el lote, el plazo límite y el motivo de la cancelación en lugar de exponer únicamente una falla genérica.

6. Agregación paralela y límites de efectos secundarios

Mantenga un estado local por tarea durante la transformación paralela y fusione en un orden definido durante la agregación. Si se permite la fusión sin ordenar, detalle las diferencias causadas por operaciones de punto flotante no asociativas; si se requiere una salida estable, preserve un índice o una secuencia de partición. Compruebe el stop token antes de una escritura externa y registre una clave de idempotencia después de confirmar. set_stopped no significa que la confirmación se haya deshecho.

7. Alternativas, pruebas y observabilidad

Construya una matriz a partir de macros de prueba de características, versiones del compilador y capacidades de la biblioteca. Si la ejecución estándar no está disponible, una implementación de compatibilidad puede preservar el contrato interno del sender; de lo contrario, use un grupo de subprocesos acotado o una ruta síncrona manteniendo consistente la semántica de valor, error y detención. Pruebe entradas vacías, lotes parciales, cancelaciones repetidas, carreras de error contra detención, agotamiento de recursos, destrucción temprana del estado de operación e inicios repetidos. Compare el rendimiento (throughput), la latencia de cola, la longitud de la cola, el tiempo de respuesta a la cancelación y las tareas inconclusas.

Respuesta de muestra de alta calidad

Modelaría la canalización como un grafo de senders perezoso: la lectura, la transformación paralela y la agregación exponen cada una sus firmas de finalización, luego connect crea un estado de operación y start lo ejecuta. E/S y CPU utilizan ejecutores diferentes, con límites de paralelismo, cola y lotes. El receiver maneja valor, error y detención por separado; cada punto interrumpible comprueba el stop token. Las escrituras externas utilizan límites de idempotencia y compensación, por lo que la cancelación nunca promete una reversión.

El ámbito de la solicitud posee el estado de operación hasta su finalización, y tanto la ruta de error como la de detención comparten la limpieza. La cadena de herramientas detecta la ejecución de C++26 y elige la estándar, una implementación de compatibilidad o una alternativa síncrona. Todas las rutas comparten pruebas de comportamiento para lotes vacíos, condiciones de carrera, respuesta a la cancelación, agotamiento de recursos y destrucción temprana. En producción, monitorearía la latencia de cola, la profundidad de la cola, la respuesta a la cancelación y las fugas para verificar que el paralelismo mejore la métrica objetivo.

Errores comunes

• Tratar la construcción del sender como el inicio del trabajo asíncrono.
• Permitir que un estado de operación se destruya cuando la función retorna.
• Usar únicamente un canal de excepciones y tratar la cancelación como un error común.
• Crear un subproceso por elemento sin límites de cola, paralelismo o memoria.
• Afirmar que un efecto secundario externo se revirtió al llegar una señal de detención.
• Dejar sin definir el ordenamiento, la tolerancia de punto flotante o las reglas de resultados parciales para la agregación paralela.
• Implementar solo una ruta de biblioteca estándar sin detección de capacidades ni alternativas.

Preguntas de seguimiento y respuestas

¿Cuándo se ejecuta realmente un sender?

La composición describe un grafo. La conexión crea un estado de operación y start inicia la operación asíncrona. Las pruebas deben cubrir la construcción, la conexión y el inicio por separado.

¿Puede una solicitud de detención terminar forzosamente una llamada al sistema?

No en general. La llamada necesita una interfaz interrumpible, un tiempo de espera o verificaciones por bloques. De lo contrario, responde tras retornar, y se debe medir el peor tiempo de respuesta.

¿Qué sucede si el error y la detención ocurren al mismo tiempo?

Defina una prioridad y una regla de finalización única para que el receiver reciba exactamente una señal terminal. Conserve tanto el error original como el motivo de la detención para fines de diagnóstico.

¿Qué sucede cuando falla una rama de when_all?

Especifique si las otras ramas continúan, reciben una solicitud de detención o finalizan la limpieza. Los recursos compartidos necesitan una propiedad delimitada por ámbito y propagación de la cancelación; el agregador no debe leer el resultado de una rama no válida.

¿Cómo hacer que la agregación sea reproducible?

Mantenga números de secuencia de partición y fusione en un orden fijo, o permita explícitamente resultados no ordenados con un límite de error. La reducción paralela no puede asumir asociatividad de punto flotante.

¿Qué ocurre si la biblioteca de producción carece de la ejecución de C++26?

Use una matriz de capacidades del compilador para seleccionar una implementación de compatibilidad o una ruta síncrona mientras preserva la semántica de finalización y las pruebas. No exponga tipos privados de una biblioteca experimental en la interfaz pública.