printf("%s: listen %s ok/r/n", myname, addr);
while (1) {
/* 等待接受客户端的连接 */
client = acl_vstream_accept(sstream, NULL, 0);
if (client == NULL) {
printf("%s(%d): accept error(%s)/r/n",
myname, __LINE__,
acl_last_strerror(ebuf, sizeof(ebuf)));
break;
}
printf("accept one/r/n");
/* 获得一个客户端连接流 */
/* 开始处理该客户端连接流 */
/**
* 向线程池中添加一个任务
* @param thr_pool 线程池句柄
* @param echo_client_thread 工作线程的回调函数
* @param client 客户端数据流
*/
acl_pthread_pool_add(thr_pool, echo_client_thread, client);
}
/* 销毁线程池对象 */
acl_pthread_pool_destroy(thr_pool);
}
/**
* 初始化过程
*/
static void init(void)
{
/* 初始化ACL库 */
acl_init();
}
/**
* 使用提示接口
* @param procname {cosnt char*} 程序名
*/
static void usage(const char *procname)
{
printf("usage: %s listen_addr/r/n", procname);
printf("example: %s 127.0.0.1:8081/r/n", procname);
getchr(); }
int main(int argc, char *argv[])
{
if (argc != 2) {
usage(argv[0]);
return (0);
}
init();
run(argv[1]);
return (0);
}
由上可以看出,创建一个并发式服务器程序也是如此的简单。 该例子可以同时运行在WIN32平台及UNIX平台(Linux, FreeBSD, Solaris-x86).
3、小结
由以上例子可以看出,ACL库屏蔽底层SOCKET的细节操作,使网络编程变得简单,使使用者可以专心于其应用,而不是拘泥于SOCKET操作上,另外结合半驻留线程池的ACL库就可以开发高效的并发网络应用来。
当然,以上例子也存在一个缺点,那就是当客户端并发连接比较高时,因为一个连接占用一个线程,所以高并发时就需要更多的线程(为了启动更多的线程,可以通过 acl_pthread_pool_set_stacksize 或 acl_pthread_pool_attr_set_stacksize 设置每个线程的堆栈为较小的值,如 500KB);而采用ACL库里的另一种编程技术--非阻塞式IO,可以使一个线程同时处理多个并发TCP连接,同时可以启动多个这样的非阻塞线程,从而可以更好地利用多核(一般是一个核可以启用一个非阻塞IO线程),将来,我们将会对此类问题进行讨论,并给出具体实例。
推荐:
怎样提高调用数学函数的程序的性能
更多相关资料:
考试大教育全国计算机等级考试在线测试平台
2010年9月全国计算机等级考试各科模拟试题冲刺
全国计算机等级考试论坛