使用C问题在线程之间传递数据答案

【问题标题】：Passing Data between thread using C issue使用C问题在线程之间传递数据
【发布时间】：2012-12-06 10:08:00
【问题描述】：

我想知道如何使用 C 语言在线程之间传递数据。

例如：X 等待来自某处的消息。
Y 向 T-X 发送有关事件的消息并等待响应。
T-X 处理事件并向 T-Y 发送响应。
T-X 等待另一条消息。

【问题讨论】：

头？线程？那么你只需要使用相同的变量......例如静态。线程共享相同的内存空间
具有某种锁定机制的全局变量？？？
听起来像管道或套接字是您正在寻找的。检查pipe(2) 和socketpair(3)。或者，如果您正在寻找一种更高效但同步性较低的用户空间方式，请查看虚拟环形缓冲区vrb(3)。

【解决方案1】：

取自https://computing.llnl.gov/tutorials/pthreads/#Mutexes 并经过修改的示例程序。这显示了如何在多个线程中使用全局声明的数据。

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

/*   
The following structure contains the necessary information  
to allow the function "dotprod" to access its input data and 
place its output into the structure.  
*/

typedef struct 
 {
   double      *a;
   double      *b;
   double     sum; 
   int     veclen; 
 } DOTDATA;

/* Define globally accessible variables and a mutex */

#define NUMTHRDS 4
#define VECLEN 100

DOTDATA dotstr; //GLOBAL DATA which is going to be accessed by different threads

pthread_t callThd[NUMTHRDS];
pthread_mutex_t mutexsum;

void *dotprod(void *arg)
{

   /* Define and use local variables for convenience */

   int i, start, end, len ;
   long offset;
   double mysum, *x, *y;
   offset = (long)arg;

   len = dotstr.veclen;
   start = offset*len;
   end   = start + len;
   x = dotstr.a;
   y = dotstr.b;

   /*
   Perform the dot product and assign result
   to the appropriate variable in the structure. 
   */

   mysum = 0;
   for (i=start; i<end ; i++) 
    {
      mysum += (x[i] * y[i]);
    }

   /*
   Lock a mutex prior to updating the value in the shared
   structure, and unlock it upon updating.
   */
   pthread_mutex_lock (&mutexsum);
   dotstr.sum += mysum;
   pthread_mutex_unlock (&mutexsum);

   pthread_exit((void*) 0);
}

int main (int argc, char *argv[])
{
   long i;
   double *a, *b;
   void *status;    

   /* Assign storage and initialize values */
   a = (double*) malloc (NUMTHRDS*VECLEN*sizeof(double));
   b = (double*) malloc (NUMTHRDS*VECLEN*sizeof(double));

   for (i=0; i<VECLEN*NUMTHRDS; i++)
    {
     a[i]=1.0;
     b[i]=a[i];
    }

   dotstr.veclen = VECLEN; 
   dotstr.a = a; 
   dotstr.b = b; 
   dotstr.sum=0;

   pthread_mutex_init(&mutexsum, NULL);             

    for(i=0; i<NUMTHRDS; i++)
        {
    /* 
    Each thread works on a different set of data.
    The offset is specified by 'i'. The size of
    the data for each thread is indicated by VECLEN.
    */
    pthread_create(&callThd[i], NULL, dotprod, (void *)i);
    }    

    /* Wait on the other threads */
for(i=0; i<NUMTHRDS; i++)
    {
  pthread_join(callThd[i], &status);
}    

   printf ("Sum =  %f \n", dotstr.sum);
   free (a);
   free (b);
   pthread_mutex_destroy(&mutexsum);
   pthread_exit(NULL);//No need of pthread_join() if pthread_exit() used.
}

【讨论】：

【解决方案2】：

线程共享相同的内存空间，因此您可以使用普通变量在线程之间共享数据。

您还提到了线程等待某个事件，这是另一个故事 - 同步。为此，您可以使用互斥锁。

【讨论】：