Estoy probando libcoro, una librería muy simple y de bajo nivel que proporciona coroutines mas o menos portables. Supuestamente, es válida para sistemas en producción.
Mi código es el siguiente:
#include <stdio.h>
#include <signal.h>
#include <unistd.h>
#include "coro.h"
// Argumentos pasados a los 'thread's.
struct Arg {
const char *message;
coro_context coro;
struct coro_stack stack;
};
// Datos de cada 'thread'.
// Args[0] es el 'thread' principal, en el que empezamos y que controla
// al resto.
struct Arg Args[4] = {
{ NULL, { 0 }, { 0 } },
{ "Mensaje 1", { 0 }, { 0 } },
{ "Mensaje 2", { 0 }, { 0 } },
{ "Mensaje 3", { 0 }, { 0 } }
};
// Selector del 'thread' actual; usado al planificar.
volatile int idx;
// 'cuerpo' de los 'thread's.
void body( struct Arg * );
// Manejador de la interrupcion SIGALRM.
void handler( int );
int main( void ) {
// Reservamos la memória a usar como pila por cada 'thread',
// y los inicializamos.
for( idx = 1; idx < 4; ++idx ) {
coro_stack_alloc( &( Args[idx].stack ), 0 );
coro_create( &( Args[idx].coro ),
(coro_func)&body,
(void *)&Args[idx],
Args[idx].stack.sptr,
Args[idx].stack.ssze );
}
signal( SIGALRM, &handler );
idx = 4;
coro_create( &( Args[0].coro ), NULL, NULL, NULL, 0 );
// Planificador.
// Los ejecutamos en secuencia, del último al primero.
while( --idx ) {
printf( "Dentro del bucle. idx = %d\n", idx );
alarm( 1 );
coro_transfer( &( Args[0].coro ), &( Args[idx].coro ) );
}
printf( "Fuera del bucle. idx = %d\n", idx );
return 0;
}
void body( struct Arg *arg ) {
printf( "%s.\n", arg->message );
while( 1 );
coro_transfer( &( arg->coro ), &( Args[0].coro ) );
printf( "Saliendo de body. idx = %d", idx );
}
void handler( int sig ) {
(void)sig;
coro_transfer( &( Args[idx].coro ), &( Args[0].coro ) );
}
La versión anterior del código, que no usa alarm()
ni signal( )
(es decir, sin hacer el cambio de tarea en el manejador de interrupciones), ni el while( 1 )
en body
, pruduce la siguiente salida:
Dentro del bucle. idx = 3
Mensaje 3.
Dentro del bucle. idx = 2
Mensaje 2.
Dentro del bucle. idx = 1
Mensaje 1.
Fuera del bucle. idx = 0
La salida esperada del código que muestro es la misma; los mensajes mostrador por pantalla deberían ser idénticos; no obstante, se muestra la siguiente:
Dentro del bucle. idx = 3
Mensaje 3.
Dentro del bucle. idx = 2
Mensaje 2.
Ahí se detiene, y el uso de la CPU se pone al 100%; es decir, se detiene dentro de la función body( )
; da la impresión de que no entra en la función manejadora de la interrupción.
Estoy seguro de que el fallo está en mi lógica de funcionamiento, pero no doy con la tecla.
EDITO
Efectivamente, hay un bucle infinito en la función body( )
; el objetivo de esta prueba de concepto es interrumpir ese bucle, cosa que sucede 2 veces, en lugar de las 3 esperadas.
Es decir, comienza trabajando bien, y en algún momento, deja de acerlo.