我想完成的是:
在主函数中创建了两个线程。它们用数字5递增一个全局变量。并向使用者线程发送一个信号,使变量递减。在每次递减之间的使用者线程中显示当前值。主线程必须等待,直到所有线程完成,然后退出。
我得到的是:
在消费者有机会显示结果之前,主函数有时会退出。我正在使用pthread_join,但它返回错误代码3。
有什么办法得到想要的结果吗?
代码如下。

#include <pthread.h>
#include <stdio.h>
#include <string.h>
#include <errno.h>

static pthread_mutex_t mtx;
static pthread_cond_t cond = PTHREAD_COND_INITIALIZER;

void *producer(void *arg);
void *consumer(void *arg);
static int avail = 0;

int main(int argc, char *argv[]){

    pthread_t cons1, prod1, prod2;

    int status;
    int t1;
    int t2;
    int t3;

    pthread_attr_t attr;
    pthread_attr_init(&attr);
    pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_JOINABLE);

    pthread_mutexattr_t mtxAttr;
    pthread_mutexattr_settype(&mtxAttr, PTHREAD_MUTEX_ERRORCHECK);
    pthread_mutex_init(&mtx, &mtxAttr);

    t1 = pthread_create(&prod1, &attr, producer, NULL);
    if(t1 != 0){
    perror("problem1");
    }
    t2 = pthread_create(&prod2, &attr, producer, NULL);
    if(t2 != 0){
    perror("problem2");
    }
    t3 = pthread_create(&cons1, &attr, consumer, NULL);
    if(t3 != 0){
    perror("problem3");
    }

    status = pthread_join(t1, NULL);
    if(status != 0){
    perror("can't join1");
    }

    status = pthread_join(t2, NULL);
    if(status != 0){
    perror("can't join2");
    printf("\n%d\n", status);
    }
    status = pthread_join(t3, NULL);
    if(status != 0){
    printf("%s",strerror(errno));
    }
    printf("\nend result \t%d\n",avail);
    printf("fin\n");
    //while(1){}
    return 0;
}

void *producer(void *arg){
    int s;
    printf("producer\n");
    s = pthread_mutex_lock(&mtx);
    avail+=5;
    s = pthread_mutex_unlock(&mtx);
    s = pthread_cond_signal(&cond);
    pthread_exit(NULL);
}

void *consumer(void *arg){
    int s;
    while(1) {
    s = pthread_mutex_lock(&mtx);
    if(s !=0 ){
        perror("lock err");
    }
    while (avail == 0) {
        s = pthread_cond_wait(&cond, &mtx);
    }
    while (avail > 0) {
        avail--;
        printf("Temp: %d \n",avail);
    }

    s = pthread_mutex_unlock(&mtx);
    }
    printf("done");
    pthread_exit(NULL);
}

最佳答案

不要在t1t2t3上加入。这些是pthread_create()函数的返回代码。改用pthread_join()打开prod1prod2cons1。请用-Wall -Wextra编译。

关于c - pthread_join不起作用,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/13976439/

10-10 16:37