0

私が達成したいこと:

メイン関数では、2 つのスレッドが作成されます。グローバル変数を数値 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);
}
4

1 に答える 1

4

t1、t2またはに参加しないでくださいt3。これらはpthread_create()関数の戻りコードです。代わりにpthread_join()on prod1、prod2andを使用してください。cons1でコンパイルしてください-Wall -Wextra。

于 2012-12-20T16:54:14.603 に答える