我正在尝试使用信号量实现合并排序,但在运行代码时遇到一些问题:
sem_t *sem;
pthread_t *t;
void *parallel_merge_sort(void *thread_id)
{
int a = *((int *) thread_id);
printf("%d. in sort\n",a);
fflush(stdout);
sem_post(&(sem[a]));
if(a % 2)
sem_wait(&(sem[a-1]));
else
sem_wait(&(sem[a+1]));
printf("%d. out sort\n",a);
fflush(stdout);
}
void main()
{
int P = 2,i;
t = calloc(P,sizeof(pthread_t));
sem = calloc(P,sizeof(sem_t));
printf("threads created\n");
fflush(stdout);
for(i=0;i<P;i++)
pthread_create(&(t[i]),NULL,(void*) ¶llel_merge_sort,(void *) &i);
for(i=0;i<P;i++)
pthread_join(t[i], NULL);
printf("threads end\n");
fflush(stdout);
}
此代码产生如下输出:
threads created
0. in sort
0. in sort
此后,它不会继续运行并等待。
问题是什么以及如何解决它?
最佳答案
无法保证新线程立即启动。这意味着您不能使用指向索引的指针,因为变量可能会在线程启动之前发生更改。
在这种情况下,线程似乎直到主线程进入第二个循环才启动,其中变量i
重置为零,因此两个线程将具有相同的索引,使两个线程尝试等待同一个信号量。
您可以使用“hack”绕过此问题并直接将 i
作为指针传递:
pthread_create(&(t[i]),NULL,(void*) ¶llel_merge_sort,(void *) i);
并在线程函数中执行以下操作:
int a = (int) thread_id;
关于c - 与信号量的合并实现,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/16254831/