2016-04-03 2 views
0

Может кто-то помочь с кодом ниже. Я не думаю, что сигнал увидит мой рабочий поток. Я ожидаю, что напечатаю STEQUESIZE 1, но это никогда не произойдет. Любая помощь будет оценена по достоинству.Сигнал состояния Pthread с рабочей нитью

выход:

Тема работы мьютекс заблокирован сделано

#include <stdlib.h> 
#include <stdio.h> 
#include <signal.h> 
#include <unistd.h> 
#include <string.h> 
#include <getopt.h> 
#include <pthread.h> 

#include <errno.h> 

// GLOBALS 
pthread_mutex_t mutexqueue; 
pthread_cond_t condworker; 
pthread_t *threadIDs; 
int STEQUESIZE=0; 

void* worker(void *arg) { 
fprintf(stdout,"Thread Started\n"); 
fflush(stdout); 

    while (1) { 
    pthread_mutex_lock(&mutexqueue); 
    fprintf(stdout,"mutex locked\n"); fflush(stdout); 
    while(STEQUESIZE == 0); 
    pthread_cond_wait(&condworker, &mutexqueue); 
    fprintf(stdout,"STEQUESIZE %d\n",STEQUESIZE); 
    fflush(stdout); 
    STEQUESIZE--; 

    pthread_mutex_unlock(&mutexqueue); 
    } 
} 

int main(int argc, char **argv) { 
    int nthreads = 1; 

    STEQUESIZE=0; 
    pthread_mutex_t mutexqueue = PTHREAD_MUTEX_INITIALIZER; 
    pthread_cond_t condworker = PTHREAD_COND_INITIALIZER; 

    threadIDs = (pthread_t *)malloc(sizeof(pthread_t)*nthreads); 
    int j; 
    for(j=0; j< nthreads;j++) 
    pthread_create(&threadIDs[j], NULL, worker, NULL); 

    sleep(2); 

    pthread_mutex_lock(&mutexqueue); 
     STEQUESIZE=1; 
     pthread_cond_signal(&condworker); 
    pthread_mutex_unlock(&mutexqueue); 

    printf("done\n"); 
    while(1); 
    return 0; 
} 
+2

Ваш 'pthread_mutex_t mutexqueue' и' pthread_cond_t condworker' в 'основной()' теневые глобальные переменные одного и того же имени. – EOF

ответ

0

Спасибо комментарий ответили на мой вопрос. У меня были глобальные и локальные переменные, названные одинаковыми.

// GLOBALS 
pthread_mutex_t mutexqueue; 
pthread_cond_t condworker; 
pthread_t *threadIDs; 
int STEQUESIZE=0; 

, а затем

int main(int argc, char **argv) { 
    int nthreads = 1; 

    STEQUESIZE=0; 
    pthread_mutex_t mutexqueue = PTHREAD_MUTEX_INITIALIZER; 
    pthread_cond_t condworker = PTHREAD_COND_INITIALIZER; 
Смежные вопросы