跪求linux下多线程网络编程问题

matchg2001

小弟想做一个客户端,同时向5个不同ip的服务器抓取数据(socket方式)
为了力求效率高,我才用了多线程的方式,由5个线程并发向5个服务器
抓取数据,
这时问题出现了,总有一定几率(10%左右)报connect错误或者读写错误
(改为串行抓取则没有问题),请教各位老大解答
ps:我给各个线程中的socket连接,读写加上互斥锁则没问题,但是这样
并发效率很低,跪求答案

albcamus

connect是主线程采用的，跟其他线程有什么关系？你不是5个线程相同样的描述符进行IO吧？

matchg2001

回albcamus: 主线程没有connect,是5个子线程分别向5个服务器并发分别connect,也就是说每个子线程内分别connect的

飞灰橙

那一定是主线程用socket生成一个fd,
然后５个子线程都来向同一个fd　connect了。

matchg2001

谢谢各位解答,我的主线程没有connect链接,都是子线程在connect链接,每个子线程都有不同的描述字

albcamus

贴一下代码吧

matchg2001

我也感觉是io冲突的问题,但是各个子线程肯定是使用了各自不同的描述字,不知道在多线程并发的时候,不同的描述字在几乎完全同时的情况下是否会有io冲突,代码简单如下:
string g_str[2];

void *threadt1(void *arg)
{
    int sock;
    pthread_detach(pthread_self());
    if ((sock = socket(AF_INET, SOCK_STREAM, 0)) < 0)
    ........
    if (connect(sock, (struct sockaddr*)&sin, sizeof(sin)) < 0)
    ........
    read....
    g_str[0] = "XXXX";
}
void *threadt2(void *arg)
{
    int sock;
    pthread_detach(pthread_self());
    if ((sock = socket(AF_INET, SOCK_STREAM, 0)) < 0)
    .......
    if (connect(sock, (struct sockaddr*)&sin, sizeof(sin)) < 0)
    ........
    read..
     g_str[1] = "XXXX";

}
main()
{
      num = 0;
      if(pthread_create(&id1,NULL,threadt1,(void *)num))  
      ........

      num = 1;
      if(pthread_create(&id2,NULL,threadt2,(void *)num))  
      ........

      if (!g_str[0].empty() && (!g_str[1].empty() )
      .......
}

因为我还有一些别的方面的考虑没用pthread_join来获取线程返回值,用了全局变量的方式,主要是请教高手关于并发出错的问题,谢谢了

飞灰橙

两个可能无关的问题
1. 不能保证 thread1在使用 num的时候，num的值仍旧是0,
即使在thread1一进去就是用num

2. g_str[0].empty()函数和 g_str[0] = "XXXX";
这个样子并非多线程安全的，empty()和"operator =()"里面其实还有好多代码哩．还不如直接用个int类型作为flag来的好．

JohnBull

sock变量哪里来的？

matchg2001

谢谢飞灰橙
这两点我都接受,不过第二点我在代码中也是用flag实现的,现在在这个简单示例里写成了判断string是否唯emtpy,呵呵,再次谢谢