pthreads的问题

Question

我真的是新来的线程，我必须做一个任务。我有一个6节点的图，我应该创建从第一个节点移动到最后一个节点的线程。除了需要在线程中完成的部分之外，我已经设置了一切。我在网上看了一些教程，但它们还不够，我遇到了一些问题，我不明白为什么。总之，这里的代码：

int main (void) { 

    pthread_t threads[NUM_THREADS]; 
    int i = 0, rc, a = 0; 
    creatGraph(); 
    rc = pthread_create(&threads[i], NULL, buscarExp(i,0), NULL); 
    if (rc) { 
     printf("ERROR al crear el funcionari %d\n,",i); 
     exit(-1); 
    } 
    pthread_exit(NULL); 
    return 0; 
} 

这里是我所需要的两个主要rutines：

void buscarDespatx(int i, int actual) { 
     if(llista[actual].id == 0) { // ja hem arribat al despatx 
      pthread_exit(NULL); 
      //buscarExp(i,actual); // el funcionari ha deixat l'expedient i va a buscar-ne un altre 
     } else { // no ha arribat al despatx 
      int seguent = rand() % llista[actual].Npares; // trio el node pare de tots els nodes pares q tindra 
      llista[actual].Proces[llista[actual].membres] = 0; // trec el proces del node actual 
      llista[actual].membres--; // decremento el nombre de processos al noded actual 
      llista[llista[actual].pares[seguent]].membres++; // incremento el nombre de processos del node pare al que anira el proces actual 
      llista[llista[actual].pares[seguent]].Proces[llista[llista[actual].pares[seguent]].membres] = i; // afegeixo el proces actual a la llista de processos del node pare que anira el proces 
      buscarDespatx(i,llista[llista[actual].pares[seguent]].id); 
      printf("BUSCAR EXP: El node %d ha estat modificat i ha marxat el proces %d\n",actual,i); 
     } 
    } 

void buscarExp(int i, int actual) { 
    if(llista[actual].id == -1) { // ja hem arribat al expedient 
     buscarDespatx(i,actual); // el funcionari te l'expedient i el va a deixar al despatx 
    } else { // no ha arribat a l'expedient 
     int node = 0; 
     if(llista[actual].dret != NULL) { // aquest node te dos fils 
      int seg = rand(); 
      if(seg%2 == 0) { // avança pel fill esq 
       llista[actual].esq->membres++; // sumo un membre al seguent node 
       llista[actual].esq->Proces[llista[actual].esq->membres] = i; // poso el proces al seguent node 
      } else { // avanço pel fill dret 
       node = 1; 
       llista[actual].dret->membres++; // sumo un membre al seguent node 
       llista[actual].dret->Proces[llista[actual].dret->membres] = i; // poso el proces al seguent node 
      } 
     } else { // nomes te fill esquerra 
      llista[actual].esq->membres++; // sumo un membre al seguent node 
      llista[actual].esq->Proces[llista[actual].esq->membres] = i; // poso el proces al seguent node 
     } 
     llista[actual].Proces[llista[actual].membres] = 0;  // elimino el funcionari del node actual 
     llista[actual].membres--; 
     printf("BUSCAR EXP: El node %d ha estat modificat i ha marxat el proces %d\n",actual,i); 
     if(node == 1) { // ha passat pel dret 
      buscarExp(i,llista[actual].dret->id); 
     } else { // passa per l'esquerra 
      buscarExp(i,llista[actual].esq->id); 
     } 
    } 
} 

所以，如果我了解线程是如何工作的，这应该做到以下几点： “主”创建pthread并开始执行路由“buscarExp（i，0）”，然后在“buscarExp（i，0）”中继续执行此例程，直到它到达图的底部if(llista[actual].id == -1)，然后返回到例程为“buscarDespatx（i，actual）”的第一个节点。当它初始化节点时，我使用pthread_exit(NULL);来终止该线程。

这是如何在我主要创建的线程行为如果代码是100％正确的？

谢谢！

Answer 1

rc = pthread_create(&threads[i], NULL, buscarExp(i,0), NULL); 

不工作。如果您查看pthread_create的文档，您会看到第三个参数（start_routine）应该是一个函数指针。但是，您的代码是第一个调用buscarExp(i,0)，然后尝试将该（错误键入的）结果作为线程函数传递给pthread_create。

您需要将具有兼容签名的功能传递给pthread_create，并使用void*向其传递任何其他参数。

此外，您的主线程正在退出，这是一个问题，因为我通过的数据生活在main()的堆栈上。最有可能的是，在你启动它们后，你想要pthread_join与你的所有线程。

事情是这样的：

struct thread_data { 
    int thread_num; 
    // Other things you want to pass here 
} 

void *thread_func(void *_data) { 
    struct thread_data *data = _data; 

    buscarExp(data->thread_num, 0) 
} 

int main (void) { 

    pthread_t threads[NUM_THREADS]; 
    struct thread_data thread_data[NUM_THREADS]; 

    int i = 0, rc, a = 0; 

    creatGraph(); 

    /* Start all threads */ 
    for (i=0; i<NUM_THREADS; ++i) { 
     thread_data[0].thread_num = i; 
     rc = pthread_create(&threads[i], NULL, thread_func, &thread_data[i]); 
     if (rc) { 
      printf("ERROR al crear el funcionari %d\n,",i); 
      exit(-1); 
     } 
    } 

    /* Wait for all threads to finish */ 
    for (i=0; i<NUM_THREADS; ++i) { 
     pthread_join(&threads[i], NULL); 
    } 
    return 0; 
}