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;