C言語 排他制御が正しく行われない原因を知りたいです

Question

問題

Cによる排他制御の入門の内容です．

スレッド1が sumに「2」を加算．
スレッド2が sumに「3」を加算．

1回の処理でスレッド1，2の合計で「5」を加算できれば良くて，

最終的に sum=50000になれば正解なのですが，30000ほどの結果になってしまいます．

排他制御に精通している方，是非よろしくお願いします！

実現したいこと

・正しく機能しない理由を知りたい
・sum=50000　になるように排他制御を修正したい．

該当のソースコード

#include <stdio.h>
#include <stdlib.h>
#include <err.h>
#include <pthread.h>
#include <unistd.h>
#include <string.h>
 
#define	TRUE	1
#define	FALSE	0

const size_t    loop_max = 10000;


int flag = FALSE;
int sum = 0;
 
void f1();
void f2();
 
int
main(int argc, char *argv[])
{
        pthread_t thread1, thread2;
        int ret1,ret2;
 
        pthread_create(&thread1,NULL,(void *)f1,NULL);
	    pthread_create(&thread2,NULL,(void *)f2,NULL);

        pthread_join(thread1,NULL);
        pthread_join(thread2,NULL);

        printf("done\n");
        printf("sum=%d\n", sum);
 
        return 0;
}

void
f1()
{
        size_t i;
 
	 printf("start  thread1\n");

        for(i=0; i<loop_max; i++){

		while(flag){}
		flag = TRUE;

              sum += 2;

		flag = FALSE;
        }

	 printf("finish thread1\n");
}
 
void
f2()
{
        size_t i;
 
 	 printf("start  thread2\n");

       for(i=0; i<loop_max; i++){

		while(flag){}
		flag = TRUE;

              sum += 3;

		flag = FALSE;
         }

	 printf("finish thread2\n");
}

Answer 1

割り込み処理が行われている。

Answer 2

pthread_mutex 使って排他すればいい。
https://qiita.com/ryo_manba/items/e48faf2ba84f9e5d31c8

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

const size_t    loop_max = 10000;

int sum = 0;
pthread_mutex_t mtx;

void f1() {
  size_t i;
  printf("start  thread1\n");
  for(i=0; i<loop_max; i++){
    pthread_mutex_lock(&mtx);
    sum += 2;
    pthread_mutex_unlock(&mtx);
  }
   printf("finish thread1\n");
}
 
void f2() {
  size_t i;
  printf("start  thread2\n");
  for(i=0; i<loop_max; i++){
    pthread_mutex_lock(&mtx);
    sum += 3;
    pthread_mutex_unlock(&mtx);
  }
   printf("finish thread2\n");
}

int main() {
  pthread_t thread1, thread2;
  pthread_mutex_init(&mtx, NULL);

  pthread_create(&thread1,NULL,(void *)f1,NULL);
  pthread_create(&thread2,NULL,(void *)f2,NULL);

  pthread_join(thread1,NULL);
  pthread_join(thread2,NULL);

  pthread_mutex_destroy(&mtx);
  printf("done\n");
  printf("sum=%d\n", sum);
  return 0;
}

実行結果:

start  thread1
start  thread2
finish thread1
finish thread2
done
sum=50000

Comments

[Rin2590]

解答ありがとうございました！
良い感じで競合を防いでくれて感謝です．
他の皆さんも参考にさせていただきます！

Answer 3

  while(flag){}

双方のスレッドで同時にこのループを抜けてしまったら排他にはなりませんな