cómo terminar un hilo de dormir en pthread?

Question

tengo hilo que duerme durante mucho tiempo, entonces se despierta para hacer algo, luego dormir de nuevo, como esto:

while(some_condition) 
{ 
    // do something 
    sleep(1000); 
} 

¿Cómo podría hacer esta salida de rosca con gracia y rápidamente?

Intenté usar pthread_cancel(), pero los hilos que duermen no se pudieron cancelar. También traté de cambiar la condición del ciclo while, pero tomará mucho tiempo para salir. Y no quiero usar pthread_kill(), ya que puede matar el hilo cuando está funcionando.

Entonces, ¿hay alguna buena idea?

Answer 1

Como alternativa a sleep, puede usar pthread_cond_timedwait con un tiempo de espera de 1000 ms. Luego, cuando quieras salir, señala la variable de condición.

Esto es similar a cómo puede hacer esto en C#/Java usando wait and notify.

Answer 2

La variable de condición clásica de UNIX es self-pipe.

int fds[2]; 
pipe2(fds, O_NONBLOCK); // requires newish kernel and glibc; use pipe + 2*fcntl otherwise 

child: 
    while (some_condition) { 
     // do something 
     struct pollfd pd = { .fd = fds[0], .events = POLLIN }; 
     int rc; 
     char c; 
     while ((rc = poll(&pd, 1, 1000000)) == -1 && errno == EINTR) 
      // not entirely correct; 1000000 should be decreased according to elapsed time when repeating after a signal interruption 
      ; 
     if (rc > 0 && (pd.revents & POLLIN) && read(fds[0], &c, 1) >= 0) 
      break; 
    } 

parent: 
    cancel() { 
     char c = 0; 
     write(fds[1], &c, 1); 
    } 

Sí, es un código bastante complicado (y no probado). Probablemente deberías simplemente usar pthread_cond_wait, requiere un pthread_mutex_t y un pthread_cond_t pero es mucho más fácil.

Answer 3

¿Usaste pthread_cleanup_push y pop? Cancelar con pthread_cancel no funciona sin ellos. Debe usarlos en pares como lo hice en el ejemplo a continuación. si olvida uno no compilará (macros de fantasía, uno tiene el '{' y el otro tiene el '}'). Incluso puedes anidar diferentes niveles de limpieza/pops. De todos modos, establecen un punto de salto largo que cancela los saltos cuando ocurre la cancelación (muy bueno). Además, si su programa de prueba no espera a que la secuencia se inicie o se detenga, es posible que no note que se está cancelando.

Ejemplo:

#include <stdio.h> 
#include <stdlib.h> 
#include <pthread.h> 

static void *ThreadProc(void * arg); 
static void unwind(__attribute__ ((unused)) void *arg); 

int _fActive = 0; 

int main(int argc, char** argv) 
{ 
pthread_t Thread; 
int  nRet; 

    nRet = pthread_create(&Thread, NULL, ThreadProc, NULL); 
    printf("MAIN: waiting for thread to startup...\n"); 
    while (_fActive == 0) 
     nanosleep(&(struct timespec){ 0, 0}, NULL); 
    printf("MAIN: sending cancel...\n"); 
    nRet = pthread_cancel(Thread); 

    printf("MAIN: waiting for thread to exit...\n"); 
    while (_fActive) 
     nanosleep(&(struct timespec){ 0, 0}, NULL); 

    printf("MAIN: done\n"); 
    return 0; 
} 

static void unwind(__attribute__ ((unused)) void *arg) 
{ 
    // do some cleanup if u want 
    printf("THREAD: unwind (all threads, canceled or normal exit get here)\n"); 
    _fActive = 0; 
} 

static void *ThreadProc(void * arg) 
{ 
    pthread_cleanup_push(unwind, arg); 
    // optional : pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL); 
    printf("THREAD: Enter Sleep\n"); 
    _fActive = 1; 
    sleep(1000000); 
    printf("THREAD: Exit Sleep (canceled thread never gets here)\n"); 
    pthread_cleanup_pop(1); 

    printf("THREAD: Exit (canceled thread never gets here)\n"); 
    return NULL; 
} 

La salida del programa:

MAIN: waiting for thread to startup... 
THREAD: Enter Sleep 
MAIN: sending cancel... 
MAIN: waiting for thread to exit... 
THREAD: unwind (all threads, canceled or normal exit get here) 
MAIN: done 

Aviso cómo el cancelar golpes de ThreadProc en el sueño punto de cancelar() y ejecuta sólo la función de desenrollado().