c - 与信号量的合并实现

Question

我正在尝试使用信号量实现合并排序，但在运行代码时遇到一些问题:

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*) &parallel_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

此后，它不会继续运行并等待。

问题是什么以及如何解决它？

Answer 1

无法保证新线程立即启动。这意味着您不能使用指向索引的指针，因为变量可能会在线程启动之前发生更改。

在这种情况下，线程似乎直到主线程进入第二个循环才启动，其中变量i重置为零，因此两个线程将具有相同的索引，使两个线程尝试等待同一个信号量。

您可以使用“hack”绕过此问题并直接将 i 作为指针传递:

pthread_create(&(t[i]),NULL,(void*) &parallel_merge_sort,(void *) i);

并在线程函数中执行以下操作:

int a = (int) thread_id;