线程池 + epoll 简单的实现

redor

我有一个比较完整的封装，呵呵，C实现的.
http://code.google.com/p/libsbase/downloads/list

redor

原帖由 zhujiang73 于 2007-5-18 15:00 发表


支持原创，希望有比较详细的应用例子程序。

关于 server->client 数据发送，如果你喜欢远程调用机制，看看这个：
http://zhujiang73.cublog.cn

http://code.google.com/p/libsbase/downloads/list


lhttpd基于libsbase实现。

zhujiang73

原帖由 redor 于 2007-5-18 18:52 发表


http://code.google.com/p/libsbase/downloads/list


lhttpd基于libsbase实现。

老兄的文档写的不全呀

redor

原帖由 zhujiang73 于 2007-5-21 14:14 发表



老兄的文档写的不全呀

Just a idea ！ 我非科班出身，没有写文档的习惯，呵呵，按照感觉做，我们公司现在用的都是我写的这个通信封装。。。。hehe

zhongfangqing

你好，请问，如果client端的socket突然关闭了，那么server端这边的epoll能不能收到一个EPOLL_IN或者EPOLL_ERR的消息，
如果能收到，怎么处理才能收到；如果收不到，那么怎样处理才能让server知道client的关闭并且作出响应，是不是要另外client向server发送心跳包来实现?
谢谢!!!

chunyv

我将testPool.cpp:30的sleep(-1);改成了sleep(1);

[root@dts threadpool]# make
g++  Log.cpp Thread.cpp Worker.cpp testPool.cpp ThreadPool.cpp Lock.cpp ListenThread.cpp Socket.cpp TaskThread.cpp -lpthread -g -o server
[root@dts threadpool]# valgrind ./server
==29429== Memcheck, a memory error detector.
==29429== Copyright (C) 2002-2005, and GNU GPL'd, by Julian Seward et al.
==29429== Using LibVEX rev 1575, a library for dynamic binary translation.
==29429== Copyright (C) 2004-2005, and GNU GPL'd, by OpenWorks LLP.
==29429== Using valgrind-3.1.1, a dynamic binary instrumentation framework.
==29429== Copyright (C) 2000-2005, and GNU GPL'd, by Julian Seward et al.
==29429== For more details, rerun with: -v
==29429==
Bind port 9999 is Successful
Listen thread is starting ....
==29429==
==29429== ERROR SUMMARY: 0 errors from 0 contexts (suppressed: 5 from 1)
==29429== malloc/free: in use at exit: 9,464 bytes in 18 blocks.
==29429== malloc/free: 18 allocs, 0 frees, 9,464 bytes allocated.
==29429== For counts of detected errors, rerun with: -v
==29429== searching for pointers to 18 not-freed blocks.
==29429== checked 21,125,256 bytes.
==29429==
==29429== LEAK SUMMARY:
==29429==    definitely lost: 0 bytes in 0 blocks.
==29429==      possibly lost: 1,440 bytes in 5 blocks.
==29429==    still reachable: 8,024 bytes in 13 blocks.
==29429==         suppressed: 0 bytes in 0 blocks.
==29429== Reachable blocks (those to which a pointer was found) are not shown.
==29429== To see them, rerun with: --show-reachable=yes
[root@dts threadpool]# uname -a
Linux dts 2.6.9-42.ELsmp #1 SMP Tue Aug 15 10:35:26 BST 2006 x86_64 x86_64 x86_64 GNU/Linux

[ 本帖最后由 chunyv 于 2007-6-4 17:09 编辑 ]

SupervisedBoy

原帖由 ruchong 于 2007-5-17 22:14 发表
连接ListenThread.cpp类发送信号通知ThreadPool.cpp类，收到信号再分配给TaskThread.cpp类，进行处理。如果没有空闲任务类，动态再创建一定数目的任务类。

个人觉得这种分发任务最好不要用信号实现,信号万一丢失了怎么办,那客户的请求就一直得不到处理,这是实际应用中不可接受的.建议采用消息通信实现,实现难度也不大,比起信号会好不少.

wisage

ddddddddddddddddddddd

ruchong

原帖由 SupervisedBoy 于 2007-6-6 22:59 发表


个人觉得这种分发任务最好不要用信号实现,信号万一丢失了怎么办,那客户的请求就一直得不到处理,这是实际应用中不可接受的.建议采用消息通信实现,实现难度也不大,比起信号会好不少.

多谢你的建议 , 回去测试一下...

kf701

用了  epoll 就 listen 一个 listenfd,  完全没有意义的工作。

你把accept得到的每个新的 fd 都送到 线程池队列里了，
就这么一个简单的工作，却写了这么一大堆代码，汗！