以下のコードでは、各スレッドから配列に要素を挿入できるかどうかを確認しようとしています。期待どおりに動作しています。しかし、どのような状況でここで競合状態が発生する可能性があるのだろうか。ここで揮発性またはセマフォが本当に必要ですか? セマフォと揮発性キーワードを削除しようとしましたが、それでも機能します。ここでも競合状態のシナリオを誘発して見たいと思います。同じ行で、各スレッドからノードを作成し、すべてのノードをリンクされたリストに入れることはできますか? これらはすべて架空のシナリオです..!!
#include <stdio.h>
#include <stdlib.h>
#include <pthread.h>
#include <semaphore.h>
#include "small_appl.h"
void * thread_func(void * arg);
int itr=0;
volatile int idx=0; //array index variable
sem_t sem1;
int arr_th[5]; //array where each thread will insert an element
int func_pointed(int a,int num_t)
{
pthread_t arr_thr[num_t];
int iter;
//create threads
for(iter=0;iter<num_t;iter++)
{
pthread_create(&arr_thr[iter],NULL,thread_func,(void *)a);
}
for (iter=0;iter<num_t;iter++)
{
pthread_join(arr_thr[iter],NULL);
}
}
int main(void)
{
int ip1=5,ip2=10,rev;
rev=sem_init(&sem1,0,0);
s_type dev_s={
.f_ptr=func_pointed,
.str="Diwakar",
.val=5
};
//initialize semaphore to 1
sem_post(&sem1);
func_aux(ip1,dev_s);
for(rev=0;rev<5;rev++)
{
printf("array : %d ",arr_th[rev]);
}
}
void * thread_func(void * arg)
{
sem_wait(&sem1);
printf("Got sema\n");
arr_th[idx]=itr;
idx++; itr++;
printf("Releasing sema\n");
sem_post(&sem1);
sleep(5);
}