printf("accept one\r\n");
/* 獲得一個(gè)客戶端連接流 */
/* 開始處理該客戶端連接流 */
/**
* 向線程池中添加一個(gè)任務(wù)
* @param thr_pool 線程池句柄
* @param echo_client_thread 工作線程的回調(diào)函數(shù)
* @param client 客戶端數(shù)據(jù)流
*/
acl_pthread_pool_add(thr_pool, echo_client_thread, client);
}
/* 銷毀線程池對(duì)象 */
acl_pthread_pool_destroy(thr_pool);
}
/**
* 初始化過程
*/
static void init(void)
{
/* 初始化ACL庫(kù) */
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);
}
由上可以看出,創(chuàng)建一個(gè)并發(fā)式服務(wù)器程序也是如此的簡(jiǎn)單。 該例子可以同時(shí)運(yùn)行在WIN32平臺(tái)及UNIX平臺(tái)(Linux, FreeBSD, Solaris-x86).
北京 | 天津 | 上海 | 江蘇 | 山東 |
安徽 | 浙江 | 江西 | 福建 | 深圳 |
廣東 | 河北 | 湖南 | 廣西 | 河南 |
海南 | 湖北 | 四川 | 重慶 | 云南 |
貴州 | 西藏 | 新疆 | 陜西 | 山西 |
寧夏 | 甘肅 | 青海 | 遼寧 | 吉林 |
黑龍江 | 內(nèi)蒙古 |