libuv发送数据问题

knull

最近在了解libuv，有了一定的认识。但是，在发送数据的时候，碰上了点问题
背景：我发现，在libuv网络库代码中，没有使用任何同步工具（mutex,condition,等等）；就是说，网络I/O不能用于多线程；
但是，我们在多线程环境下，我可以把数据安全的放到对应的I/O线程；但是，怎么触发I/O线程去获取这个数据并且发送出去？
我看代码，write_cb只有在uv_write的时候可以注册？

由于我刚刚了解，肯定有认识不足的地方（可能就是我自己看错了），希望大侠能指点一二

谢谢

yulihua49

knull 发表于 2015-08-27 10:53
最近在了解libuv，有了一定的认识。但是，在发送数据的时候，碰上了点问题
背景：我发现，在libuv网络库代 ...

每个连接，同时只能属于一个线程，所以不要锁。

连接池的管理过程要用锁，当一个连接分配给一个线程后就不用锁了。

knull

回复 2# yulihua49
首先，谢谢你的回复；
我的问题是：一般情况下，epoll是一个线程；send是另一个线程；就是说，一个链接，肯定会有属于两个线程的情况；
另外，你说的一个链接，属于一个线程，是不是太奢侈了

   

windoze

回复 1# knull

1. 
   
2. $ grep -Rn pthread_mutex libuv
   
3. libuv/configure.ac:46:AC_CHECK_LIB([pthread], [pthread_mutex_init])
   
4. libuv/include/pthread-fixes.h:45:  pthread_mutex_t  mutex;
   
5. libuv/include/uv-unix.h:134:typedef pthread_mutex_t uv_mutex_t;
   
6. libuv/src/unix/fs.c:621:  static pthread_mutex_t lock = PTHREAD_MUTEX_INITIALIZER;
   
7. libuv/src/unix/fs.c:622:  pthread_mutex_lock(&lock);
   
8. libuv/src/unix/fs.c:679:  pthread_mutex_unlock(&lock);
   
9. libuv/src/unix/fsevents.c:495:  static pthread_mutex_t global_init_mutex = PTHREAD_MUTEX_INITIALIZER;
   
10. libuv/src/unix/fsevents.c:501:  pthread_mutex_lock(&global_init_mutex);
    
11. libuv/src/unix/fsevents.c:567:  pthread_mutex_unlock(&global_init_mutex);
    
12. libuv/src/unix/pthread-fixes.c:66:  pthread_mutex_init(&barrier->mutex, NULL);
    
13. libuv/src/unix/pthread-fixes.c:73:  pthread_mutex_lock(&barrier->mutex);
    
14. libuv/src/unix/pthread-fixes.c:79:    pthread_mutex_unlock(&barrier->mutex);
    
15. libuv/src/unix/pthread-fixes.c:88:  pthread_mutex_unlock(&barrier->mutex);
    
16. libuv/src/unix/pthread-fixes.c:95:  pthread_mutex_destroy(&barrier->mutex);
    
17. libuv/src/unix/thread.c:91:  return -pthread_mutex_init(mutex, NULL);
    
18. libuv/src/unix/thread.c:93:  pthread_mutexattr_t attr;
    
19. libuv/src/unix/thread.c:96:  if (pthread_mutexattr_init(&attr))
    
20. libuv/src/unix/thread.c:99:  if (pthread_mutexattr_settype(&attr, PTHREAD_MUTEX_ERRORCHECK))
    
21. libuv/src/unix/thread.c:102:  err = pthread_mutex_init(mutex, &attr);
    
22. libuv/src/unix/thread.c:104:  if (pthread_mutexattr_destroy(&attr))
    
23. libuv/src/unix/thread.c:113:  if (pthread_mutex_destroy(mutex))
    
24. libuv/src/unix/thread.c:119:  if (pthread_mutex_lock(mutex))
    
25. libuv/src/unix/thread.c:130:  err = pthread_mutex_trylock(mutex);
    
26. libuv/src/unix/thread.c:139:  if (pthread_mutex_unlock(mutex))
    

复制代码

谁说libuv没用mutex？

yulihua49

knull 发表于 2015-08-27 14:33
回复 2# yulihua49
首先，谢谢你的回复；
我的问题是：一般情况下，epoll是一个线程；send是另一个线程； ...

1.epoll_wait可以是很多线程,但每个线程一次只可以得到一个连接。
2.如果epoll_wait一次获取多个事件，它将分发到其他线程，分出去后，它就不再拥有它。所以还是一个线程在处理。
3.线程也可以从连接池获取连接，在一定时间内，一个连接只属于一个线程。

违背上述原则，一个连接同时被多个线程处理，就是“惊群”？如果你一定要这样处理，就必须加锁，一个完了再另一个，串行化。

yulihua49

windoze 发表于 2015-08-27 14:46
回复 1# knull 谁说libuv没用mutex？

那些都应该是资源管理所用。真正的IO还要加锁吗？

windoze

回复 6# yulihua49

最基本的I/O，比如read/write，不一定是原子操作，所以加锁是必须的。

knull

windoze 发表于 2015-08-27 14:46
回复 1# knull 谁说libuv没用mutex？

谢谢你的回复啊，热心的朋友；
我的意思是，libuv库中，网络I/O相关代码，是 没有用 到锁；并不是说它 没有 。
libuv本身是提供这些同步工具，但是在I/O中没有用到；在线程池等地方，用了。

knull

回复 5# yulihua49
再次感谢；但是，我不是很能理解
你说的模型，是不是一个epoll_wait就管理一个链接？然后，一个线程管理一个epoll？
一般的模型，不都是N多个链接，放在一个epoll中管理；有事件过来，那么就激活这个链接？
如果是我说的模型，要将数据分发到其他work线程，那么还是需要锁的，这个似乎没有异议。
但是，其他线程处理完数据之后，要对对应的链接发送数据，可以直接用uv_write；但是，我测试发现，如果uv_write和epoll线程不是同一个的话，是存在问题的（虽然，我也觉得，理论上是不应该有问题的）。暂时，没有找到问题根本原因？但是，现象是，epoll_wait触发了写事件，导致两个线程同时写；但是，写队列没有锁，所以就挂壁了。

   

cokeboL

可以放加锁的队列，开个uv的timer在io线程里发