Pthread mit pthread_cond_wait innerhalb Signalhandle blockiert

Question

Ich möchte ein Programm schreiben, die alle anderen Pthreads ohne Hauptthread stoppen kann (ich auflegen) pthread_kill, um ein Signal an den Ziel-Thread zu senden, um seine Signal-Handler, die blockieren kann, zu rufen selbst. Aber ich bin stecken geblieben. Hier ist der Code unten: (Dies gilt)

#include <iostream> 
#include <signal.h> 
#include <pthread.h> 
#include <unistd.h> 
#include <cassert> 

using namespace std; 

pthread_mutex_t _mutex; 
pthread_cond_t cond; 

void cur_thread_wait(int sig) 
{ 
    cout << pthread_self() << endl; 

// pthread_mutex_lock(&_mutex); 
    pthread_cond_wait(&cond, &_mutex); 
// pthread_mutex_unlock(&_mutex); 
} 

void signal_all() 
{ 
    pthread_cond_broadcast(&cond); 
} 

void *print(void *) 
{ 
    pthread_detach(pthread_self()); 
    for (int i = 0; i < 100; i ++) { 
     cout << dec << i << endl; 
    } 
    return nullptr; 
} 


int main(int argc, char *argv[]) 
{ 
    pthread_mutex_init(&_mutex, nullptr); 
    pthread_cond_init(&cond, nullptr); 

    signal(SIGUSR1, cur_thread_wait); 

    pthread_t pid1, pid2, pid3; 
    pthread_create(&pid1, nullptr, print, nullptr); 
    pthread_create(&pid2, nullptr, print, nullptr); 
    pthread_create(&pid3, nullptr, print, nullptr); 

// usleep(400); 

    pthread_kill(pid1, SIGUSR1); 
    pthread_kill(pid2, SIGUSR1); 
    pthread_kill(pid3, SIGUSR1); 

    signal_all(); 


    pthread_exit(nullptr); 
} 

In der Tat, ich glaube, es gibt wirklich keine Notwendigkeit zu erstellen mutex ... Ich bin ein Neuling auf Linux-Programmierung. Wie kann ich dieses Problem beheben? Vielen Dank.

Answer 1

Sie tun müssen den Mutex vor dem Aufruf pthread_cond_wait sperren; Es erwartet, dass es gesperrt wird, es entsperrt es, wartet auf die Bedingung, die geltend gemacht werden soll, und schließt es dann wieder, bevor es zu Ihnen zurückkehrt.

Von pthread_cond_wait(3p):

int pthread_cond_wait(pthread_cond_t *restrict cond, 
    pthread_mutex_t *restrict mutex); 

Die pthread_cond_timedwait() und pthread_cond_wait() Funktionen auf einer Zustandsgröße blockieren soll. Die Anwendung muss sicherstellen, dass diese Funktionen mit Mutex vom aufrufenden Thread gesperrt aufgerufen werden; Andernfalls tritt ein Fehler (für PTHREAD_MUTEX_ERRORCHECK und robuste Mutexe) oder undefiniertes Verhalten (für andere Mutexe) auf.