// 服務(wù)監(jiān)聽(tīng)套接字
int lsfd;
// 當(dāng)前連接套接字
int fd;
// 連接隊(duì)列
list fdlist;
while (true)
{
     // 等待套接字事件
     wait_event(lsfd, fdlist);
     // 檢查是否是監(jiān)聽(tīng)套接字的事件
     if (event(lsfd))
     {
         // 接收新的連接.
         fd = accept(lsfd);
         // 把新的連接放入連接隊(duì)列
         push(fd, fdlist);
         // 通知系統(tǒng)有新的連接
         // on_connect通常需要進(jìn)行數(shù)據(jù)庫(kù)和日志操作
         on_connect(fd);
     }
     while (-1 != (fd = event(fdlist)))
     {
         // 連接上有可接收的數(shù)據(jù)
         if (is_read(fd))
         {
              // 接收數(shù)據(jù)
              recv(fd);
              // 處理數(shù)據(jù)
              // proc_data通常需要進(jìn)行數(shù)據(jù)庫(kù)和日志操作
              proc_data(fd);
              // 發(fā)送數(shù)據(jù)
              send(fd);
         }
         // 連接已經(jīng)斷開(kāi)
         if (is_disconnect(fd))
         {
              // 關(guān)閉連接
              close(fd);
              // 把連接從連接隊(duì)列清除
              pop(fd);
              // 通知系統(tǒng)連接斷開(kāi)
              // on_disconnect通常需要進(jìn)行數(shù)據(jù)庫(kù)和日志操作
              on_disconnect(fd);
         }
     }
}


// 連接上有可接收的數(shù)據(jù)
if (is_read(fd))
{
     // 接收等差數(shù)列尾數(shù)
     int n = recv(fd);
     // 調(diào)用處理函數(shù)
     int m = proc_data(n);
     // 回復(fù)計(jì)算結(jié)果到客戶端
     send(fd, m);
}
// 處理等差數(shù)列計(jì)算
int proc_data(int n)
{
     // 計(jì)算等差數(shù)列
     int m = 0;
     for (int i = 1;i <= n;i ++)
     {
         m += i;
     }
     // 把M寫(xiě)入數(shù)據(jù)庫(kù)
     db_query(m);
     // 把M寫(xiě)入日志
     log(m);
     // 返回
     return m;
}


// 連接上有可接收的數(shù)據(jù)
if (is_read(fd))
{
     // 觸發(fā)線程執(zhí)行
     trigger_thread(fd, thread_proc);
}
// 線程處理函數(shù)
void thread_proc(fd)
{
     // 接收等差數(shù)列尾數(shù)
     int N = recv(fd);
     // 調(diào)用處理函數(shù)
     int E = proc_data(N);
     // 回復(fù)計(jì)算結(jié)果到客戶端
     send(fd, E);
}
// 處理等差數(shù)列計(jì)算
int proc_data(int N)
{
     // 計(jì)算等差數(shù)列
     int M = 0;
     for (int i = 1;i <= N;i ++)
     {
         M += i;
     }
     // 把M寫(xiě)入數(shù)據(jù)庫(kù)
     db_query(M);
     // 把M寫(xiě)入日志
     log(M);
     // 返回
     return M;
}


while (true)
{
     // 等待套接字事件
     wait_event(lsfd, fdlist);

// 監(jiān)聽(tīng)線程
void listen_thread()
{
     // IOCP對(duì)象
     HANDLE iocp;
     // 監(jiān)聽(tīng)套接字
     int lsfd;
     // 用戶對(duì)象指針
     void * ptr;
     while (true)
     {
         // 接收新的連接
         int fd = accept(lsfd);
         // 放入iocp隊(duì)列
         iocp_push(iocp, fd, ptr);
     }
}
// 請(qǐng)求處理線程
void proc_thread()
{
     // IOCP對(duì)象
     HANDLE iocp;
     // 連接套接字
     int fd;
     // 用戶對(duì)象
     void * ptr;
     // 接收的數(shù)據(jù)
     char * data;
     while (iocp_event(&fd, & ptr))
     {
         // 如果是連接事件
         if (is_connect(fd))
         {
              // 通知系統(tǒng)要接收數(shù)據(jù)
              // 這個(gè)過(guò)程不阻塞，下次接收完畢會(huì)通知
              trigger_recv(iocp, data);
         }
         // 如果是接收到數(shù)據(jù)的事件
         else if (is_recved(fd, &data))
         {
              // 處理接收的數(shù)據(jù)
              proc_data(data, ptr);
              // 回復(fù)處理結(jié)果
              send(data);
         }
         // 如果是斷開(kāi)事件
         else if (is_disconnect(fd))
         {
         }
     }
}