在下面的代码中,我只是想看看我是否能够从每个线程插入一个元素到数组中。它按预期工作。但后来我想知道,在什么情况下,这里可能会出现竞赛状况。我真的需要在这里变动吗,还是信号量?我试图删除信号量和易变的关键字,仍然有效。我想在这里引发并看到竞赛情况。在同一行上,我可以从每个线程创建一个节点,并将所有节点放入链接列表中?这些都是虚构的场景..!C多线程:竞态条件场景
#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);
}
在C中,'volatile'并不意味着你的想法。特别是,它不同于一个原子变量或任何进行内存同步的东西。 –
竞态条件不容易产生。C语言中的volatile只是为了告诉编译器不要为这个变量优化,而不是为了多线程目的。 – JackyZhu
在此代码中,您不需要任何位置的“volatile”*。你也不需要信号量,因为无论如何你真正使用它是一个互斥量(如果你抛出信号量,你就需要*)*。 – WhozCraig