计算机等考二级C++：利用ACL开发并发网络服务器

　　1、概述

　　本节结合 "利用ACL库开发高并发半驻留式线程池程序" 和 "利用ACL库快速创建你的网络程序" 两篇文章的内容，创建一个简单的线程池网络服务器程序。

　　2、并发式网络通信实例

　　C代码

　　#include　"lib_acl.h"　/*　先包含ACL库头文件　*/

　　#include　

　　#include　

　　/**

　　*　单独的线程处理来自于客户端的连接

　　*　@param　arg　{void*}　添加任务时的对象

　　*/

　　static　void　echo_client_thread(void　*arg)

　　{

　　ACL_VSTREAM　*client　=　(ACL_VSTREAM*)　arg;

　　char　buf[1024];

　　int　　n;

　　/*　设置客户端流的读超时时间为30秒　*/

　　ACL_VSTREAM_SET_RWTIMO(client,　30);

　　/*　循环读客户端的数据，直到其关闭或出错或超时　*/

　　while　(1)　{

　　/*　等待读客户端发来的数据　*/

　　n　=　acl_vstream_read(client,　buf,　sizeof(buf));

　　if　(n　==　ACL_VSTREAM_EOF)

　　break;

　　/*　将读到的数据写回至客户端流　*/

　　if　(acl_vstream_writen(client,　buf,　n)　==　ACL_VSTREAM_EOF)

　　break;

　　}

　　/*　关闭客户端流　*/

　　acl_vstream_close(client);

　　}

　　/**

　　*　创建半驻留线程池的过程

　　*　@return　{acl_pthread_pool_t*}　新创建的线程池句柄

　　*/

　　static　acl_pthread_pool_t　*create_thread_pool(void)

　　{

　　acl_pthread_pool_t　*thr_pool;　/*　线程池句柄　*/

　　int　max_threads　=　100;　/*　最多并发100个线程　*/

　　int　idle_timeout　=　10;　/*　每个工作线程空闲10秒后自动退出　*/

　　acl_pthread_pool_attr_t　attr;　/*　线程池初始化时的属性　*/

　　/*　初始化线程池对象属性　*/

　　acl_pthread_pool_attr_init(&attr);

　　acl_pthread_pool_attr_set_threads_limit(&attr,　max_threads);

　　acl_pthread_pool_attr_set_idle_timeout(&attr,　idle_timeout);