线程之间能不能管道啊！

应该没有问题的。

管道都是先进先出的呀。

实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？

apollolegend

丰衣足食

论坛徽章:: 0

3楼 [报告]

发表于 2003-09-09 09:02 |只看该作者

线程之间能不能管道啊！

Pipe一般用于进程之间，系统有开销，且效率不是太好。所以同一进程的不同线程，不建议使用Pipe。

实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？

蓝色键盘

荣誉版主

论坛徽章:: 1

4楼 [报告]

发表于 2003-09-09 10:41 |只看该作者

线程之间能不能管道啊！

或许有些需要共享的东西可以设计为全局变量。
如果不能满足要求，可以考虑线程之间的通讯机制。

实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？

mills

稍有积蓄

论坛徽章:: 0

5楼 [报告]

发表于 2003-09-09 12:32 |只看该作者

线程之间能不能管道啊！

还有我的线程开了怎么没反映啊，线程里的好象都没做啊
我的主程序执行到开线程的地方在下面就没了怎么回事呢？？？？
fd全局的
mask,sdmax,SOCKMAX都是全局的
void *Recvdata(void *)
{
int status = 0;
int nbytes = 0;
char buffer[BUF_SIZE] ="0";
char str[BUF_SIZE] = "0";
char pipedata[2*BUF_SIZE]= "0";
struct fd_set rmask;
close(fd[0]);
for ( ; ; )
{
rmask = mask;
status = select(sdmax + 1, &rmask, ZERO, ZERO, NULL);
if (status >; 0)
{
         for(int i = 0; i < SOCKMAX; i++)
   {
   if (FD_ISSET(sd, &rmask))
   {
   bzero(pipedata,2*BUF_SIZE);
   bzero(buffer,BUF_SIZE);
   nbytes = read(sd, buffer, BUF_SIZE);
   bzero(str,BUF_SIZE);
   getNodeId(sd,str);
   if (nbytes >; 0)
   {
   strncpy(pipedata, buffer, BUF_SIZE);
   strncat(pipedata,str,BUF_SIZE);
   printf("node:%s\n",pipedata);
   write(fd[1], pipedata, 2*BUF_SIZE);
   }
   if(nbytes <= 0)
   {
   close(sd);
   if (sd >;= sdmax)
   sdmax = sd[i-1];
   SOCKMAX--;
   }//end if close
   }//end if FD_ISSET
   }//end for
   if (status < 0)break;
}
}
}
pthread_create(&threadrecv,PTHREAD_CREATE_DETACHED,Recvdata,NULL);