pthreads 没有串行执行

Question

我是这些 pthread 的新手。我编写了一个程序，以便按顺序显示，而不是随机显示数字。我为此使用了 pthrea_join() 方法。程序如下：

int cnt=0,i=1;
pthread_t th[10];
int printmsg()
{
  cnt++;
  printf( "thread no. %d\n",cnt);
}
void tosync()
{
  if(i>0)
  pthread_join(th[i-1],NULL); // <---here i am blocking the previous thread..                         
  printmsg();
}
void main(void)
{
  pthread_create(&th[0], NULL,(void*)&tosync, NULL);
  for( i=1;i<10; i++){
    pthread_create(&th[i],NULL, (void*) &tosync, NULL);
  } 
  int y;
  for(int i=0; i<10; i++)
    pthread_join(th[i],NULL);
  return;
}

我仍然随机获取数字... 请。帮助

Answer 1

您应该将一些内容传递给您的tosync 例程，以便每个线程都知道它应该等待哪个线程。此外，第一个线程不应该等待任何人。如果您对线程启动例程使用正确的签名，则可以传入一个参数。

void * tosync(void *arg)
{
  pthread_t *me = (pthread_t *)arg;
  if (me > th) pthread_join(me[-1],NULL);
  printmsg();
  return 0;
}

main 应该返回 int。它的循环现在被简化了，因为启动例程不再需要强制转换。由于每个线程都已经加入了它的前任，main 线程只需要加入最后一个线程。

int main(void)
{
  for( i=0;i<10; i++){
    pthread_create(&th[i],NULL, tosync, &th[i]);
  }
  pthread_join(th[9],NULL);
  return 0;
}

Answer 2

pthread_join(th[i-1],NULL) 这一行有一些问题。当你创建一个线程时，你会创建 i 的值。认为 创建前三个线程操作系统切换第三线程启动和操作系统切换到它创建其余线程的主线程。创建所有线程后 i 的值为 10/ 现在假设操作系统切换到第三线程然后他等待 10-1 = 9th 线程完成并类似地继续。所以最终它总是随机打印。你的策略是错误的。

试试这个

int cnt=0,i=1;
pthread_t th[10];
int printmsg()
{
cnt++;
printf( thread no. %d\n",cnt);
}
void tosync()
{

printmsg();
}
void main(void)
{
pthread_create(&th[0], NULL,(void*)&tosync, NULL);
for( i=1;i<10; i++){
pthread_create(&th[i],NULL, (void*) &tosync, NULL);
pthread_join(th[i],NULL); // <---here i am blocking the previous thread..   
} 

return;
}

Answer 3

另一种方法：

#include <stdio.h>
#include <pthread.h>

struct threadData{
    int id;
    pthread_t prev;
};


void tosync(void *data)
{
    struct threadData *td=data;
    if ((*td).prev!=0){
        printf("%i waiting\n",(*td).id);
        fflush(0);
        pthread_join((*td).prev,NULL); // <---here i am blocking the previous thread..                         
    }
    printf("%i runnning\n",(*td).id);
    fflush(0);
    free(td);
}

int main(void)
{
    int i;
    struct threadData *td;
    pthread_t nextThreadID=0;
    for( i=0;i<10; i++){
        td=malloc(sizeof(struct threadData));
        (*td).prev=nextThreadID;
        (*td).id=i;
        pthread_create(&nextThreadID,NULL, (void*) &tosync, (void *)td);
    } 
    pthread_join(nextThreadID,NULL);
    return 0;
}

Answer 4

在toSync 函数中，您使用的是i 值，问题是当toSync 函数运行时您不知道i 具有什么值。

在极端情况下，所有线程的值可能为 10，如果创建线程的循环在任何创建的线程可以运行之前运行，就会发生这种情况。

干净的解决方案是将i 值作为参数传递给pthread_create，并让toSync 使用它而不是全局i。例如

int *id = (int*)malloc(sizeof(int));
*id = i;
pthread_create(&th[i],NULL, (void*) &tosync, id);

其他需要考虑的事情：

1. toSync 需要对 id 为 0 的线程进行特殊处理，因为它没有任何前任等待
2. main 中的最后一个循环不应在线程 0-8 上调用 pthread_join，因为它们已经加入。在同一个线程上多次调用pthread_join的结果是undefined

Answer 5

发生的情况是您的tosync() 方法使用全局变量i，而不是在线程实际启动时知道i 的值。如果您想将i（或此处指向前一个pthread_t 的指针）传递给tosync，以便它真正记住它应该加入哪个线程，您需要通过pthread_create 传递它，类似于；

void* tosync(void* ptr)
{
  pthread_t* threadIndex = (pthread_t*)ptr;
  if(threadIndex != NULL)
      pthread_join(*threadIndex, NULL); // <---here i am blocking the previous thread..                         
  printmsg();
}

...in the loop...

pthread_create(&th[i], NULL, tosync, &th[i-1]);

它是 pthread_create 的最后一个参数，将在您的方法中作为 threadIndex 传入，如果其中包含索引，则每个线程都会知道其单独的索引。