マルチスレッドに関して

Question

初期値 を0 として，この変数を並列に動作する3 つのスレッドで mutex を用いて排他制御し，協力して30 まで1 ず つ加算する（各スレッドがそれぞれ1 ずつ計10 回加算するように）プログラ ムを実現したいです

発生している問題・エラーメッセージ

the process joins with thread th1
とだけ表示されてプログラムが実行されません

該当のソースコード

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

int count = 0;

void *calc(void *arg);

 typedef struct {
	 char name[64];
     pthread_mutex_t *mlock;
} mythread_args_t;

int main(void)
{
	pthread_t th1, th2, th3;
	void *rval;

	pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
	mythread_args_t args1 = {"th1", &mutex};
	mythread_args_t args2 = {"th2", &mutex};
	mythread_args_t args3 = {"th3", &mutex};

	srand((unsigned int) time(NULL));

	//start
	if (pthread_create(&th1, NULL, calc, (void *) &args1) != 0) {
		perror("Thread creation failed.\n");
		exit(EXIT_FAILURE);
	}

	if (pthread_create(&th2, NULL, calc, (void *) &args2) != 0) {
		perror("Thread creation failed.\n");
		exit(EXIT_FAILURE);
	}

	if (pthread_create(&th3, NULL, calc, (void *) &args3) != 0) {
		perror("Thread creation failed.\n");
		exit(EXIT_FAILURE);
	}

	//wait 
	printf("the process joins with thread th1\n");
	if (pthread_join(th1, &rval) != 0) {
		perror("Failed to join with th1.\n");
	}
	printf("the process joins with thread th2\n");
	if (pthread_join(th2, &rval) != 0) {
		perror("Failed to join with th2.\n");
	}
	printf("the process joins with thread th3\n");
	if (pthread_join(th3, &rval) != 0) {
		perror("Failed to join with th3.\n");
	}

	return 0;
}

void *calc(void *arg)
{
	mythread_args_t *targs = (mythread_args_t *) arg;
	int prev;
	int i;

	pthread_mutex_lock(targs->mlock);

	for(i=0;i<10;i++){
		pthread_mutex_lock(targs->mlock);
		prev = count;
		
		sleep(rand() % 5);
		
		count = prev + 1;
		printf("[%s] %d -> %d\n", (char *)arg, prev, count);
		sleep(rand() % 5);

	}
	pthread_mutex_unlock(targs->mlock);
	
	pthread_exit(NULL);
}

原因わかる方いらっしゃいましたら教えていただきたいです。

Answer 1

※ これが原因か自信はないが:

void *calc(void *arg)
{
    mythread_args_t *targs = (mythread_args_t *) arg;
    int prev;
    int i;

    pthread_mutex_lock(targs->mlock); /* ココと */

    for(i=0;i<10;i++){
        pthread_mutex_lock(targs->mlock); /* ココ */
        prev = count;

        sleep(rand() % 5);

        count = prev + 1;
        printf("[%s] %d -> %d\n", (char *)arg, prev, count);
        sleep(rand() % 5);

    }
    pthread_mutex_unlock(targs->mlock);

    pthread_exit(NULL);
}

都合11回 lockしてます。
正しくは:

void *calc(void *arg)
{
    mythread_args_t *targs = (mythread_args_t *) arg;
    int prev;
    int i;

    for(i=0;i<10;i++){
        pthread_mutex_lock(targs->mlock); /* ココから */
        prev = count;

        sleep(rand() % 5);

        count = prev + 1;
        pthread_mutex_unlock(targs->mlock); /* ココまで排他 */
        printf("[%s] %d -> %d\n", (char *)arg, prev, count);
        sleep(rand() % 5);

    }

    pthread_exit(NULL);
}

ってとこかしら。

Comments

[退会済みユーザー]

すみません。やはり、
the process joins with thread th1
の後プログラムが進みません。

[episteme]

"やはり"って? 何したんです?

[退会済みユーザー]

日本語おかしくてすいません。指摘があったようにプログラムを変更したのですが結果が変わらなかったということです。説明不足ですいません。２回めの指摘通りにロックする区間を変更してみたら正常に実行できました。ありがとうございます。

[episteme]

> 指摘があったようにプログラムを変更したのですが
いや、僕は提示されたコードをそのまま貼って疑問点を指摘しただけ。

[退会済みユーザー]

すみません。ロックの位置を変えたりいろいろいじってたので変更したと思ってました。