同一个sock fd上两个线程同步问题

weishuo1999

首先recv返回-1不是代表断开，至少在一些情况下不是，其次为什么要分开读写呢，其实大多是情况下send的函数的性能很高的，基本上是10几个微妙的水平，分开2个线程反而加重了cpu的调度，性能真的好吗？

Dannysd

回复 11# weishuo1999


    自始至终都没提过性能两个字

    帖子明显没有问recv函数的应用

    你看我都不知道说什么好了。。。。。。。。。。。

   

folklore

折腾， 请用两个socket...

timespace

回复 1# Dannysd
大神们的建议是合理的，但老板估计不愿听“这代码太垃圾，要彻底重写”。

几个建议：
1. 线程同步是必须的。这关系到程序逻辑的正确性，和架构无关。

2. 简化同步逻辑。A（收线程）做主动控制，B（发线程）做被动响应。以连接状态为例，只能由A修改，B只读。

3. 伪代码。quick & dirty的fix大概就是这样，细节上你继续完善吧。

1. /*
   
2. * conn_mutable信号量初值为0，连接状态是否可修改
   
3. * conn_ready信号量初值为0 ，连接是否就绪
   
4. * conn_ok初值为false，推荐__atomic / __sync存取
   
5. */
   
6. void *thread_recv(void *arg)
   
7. {
   
8. 
   
9. while (!sys_exit) {
   
10.      sem_wait(&conn_mutable);
    
11.      reconnect(); /* 如果fd已打开，先关闭 */
    
12.      conn_ok = true;
    
13.      sem_post(&conn_ready);
    
14. 
    
15.      while (1) {
    
16.           ret = recv(fd, …);
    
17.           if (ret > 0) {
    
18.                /* 正常接收 */
    
19.           } else if (ret == 0 ) {
    
20.                /* 正常关闭 */
    
21.           } else {
    
22.                if (errno == EINTR || errno == EAGAIN) continue;
    
23.                conn_ok = false;
    
24.                break;
    
25.           }
    
26.      }
    
27. }
    
28. 
    
29. return NULL;
    
30. }
    
31. 
    
32. void *thread_send(void* arg)
    
33. {
    
34. 
    
35. while (!sys_exit) {
    
36.      sem_post(&conn_mutable);
    
37.      sem_wait(&conn_ready);
    
38. 
    
39.      while (conn_ok) {
    
40.           ret = send(fd, ...);
    
41.           if (ret > 0) {
    
42.                /* 正常发送 */
    
43.           } else {
    
44.                if (errno == EINTR || errno == EAGAIN) continue;
    
45.                break;
    
46.           }
    
47.      }
    
48. }
    
49. 
    
50. return NULL;     
    
51. }

复制代码

socay2

windoze 发表于 2014-04-15 11:05
回复 7# Dannysd

说的就是应用层协议，底下的TCP谁让你去改了。

我感觉读和写放在两个线程是有可取的场景。
比如需要读 M 次， 写 N 次的情况。如果放在一个线程线性执行，势必会在第一次读写完成后才能下一次处理。
此时，如果将读取的数据放入一个缓存，让写线程慢慢从缓存中取数据分发出去，岂不是有提高响应速度！

Dannysd

回复 14# timespace


    谢谢timespace，感谢理解啊！！说多了都是泪

    现在已经是接收来实现管理，不过也没用信号量这么高上大的东西

    因为创建有先后顺序，所以不会存在，fd没就绪就读或写的情况

    发送的部分是这样处理的，如果fd被清0，发送失败也没关系，只要free(data)就好了

    （开始想用锁来查看fd，但是如果链接断开，不论当前锁没锁，这个fd都是不可用的，所以无效）

    很粗陋，但也不知道怎么搞好

windoze

回复 15# socay2

那你用一个还是多个写线程？用一个写线程实质上没有提高处理速度，因为读写线程基本没有一起运行的，总是一个等另一个；用多个写线程就有可能导致多个应答乱序，除非你的协议专门处理了这种情况，否则实际上给客户端增加了复杂度而没带来什么好处。
读写分离的场景确实是有的，但很罕见，在TCP这样的流协议上就更罕见。

Dannysd

回复 15# socay2


    感谢socay2回复

    就像FTP协议里传输文件一样，就是会一直发送数据，client只要确认收的数据没有错误就好

    并不对server端返回什么数据，就是非常类似于这种情况

Dannysd

回复 17# windoze


    一个链接对应一个fd，一个fd对应一读一写两个线程，暂时没想到可能会出现什么问题

    效率暂且不计吧，因为大神们经验是非常丰富的，肯定有各自独到的见解，如果算上的话，势必会引发大争论

    诚然，这个需求确实也比较少见

socay2

windoze 发表于 2014-04-15 22:25
回复 15# socay2

那你用一个还是多个写线程？用一个写线程实质上没有提高处理速度，因为读写线程基本没 ...

读写线程基本没有一起运行的，总是一个等另一个 为什么要等？发送断只要有数据就发送，接收端只要缓存够就接收。