// 服务监听套接字
int lsfd;
// 当前连接套接字
int fd;
// 连接队列
list fdlist;
while (true)
{
     // 等待套接字事件
     wait_event(lsfd, fdlist);
     // 检查是否是监听套接字的事件
     if (event(lsfd))
     {
         // 接收新的连接.
         fd = accept(lsfd);
         // 把新的连接放入连接队列
         push(fd, fdlist);
         // 通知系统有新的连接
         // on_connect通常需要进行数据库和日志操作
         on_connect(fd);
     }
     while (-1 != (fd = event(fdlist)))
     {
         // 连接上有可接收的数据
         if (is_read(fd))
         {
              // 接收数据
              recv(fd);
              // 处理数据
              // proc_data通常需要进行数据库和日志操作
              proc_data(fd);
              // 发送数据
              send(fd);
         }
         // 连接已经断开
         if (is_disconnect(fd))
         {
              // 关闭连接
              close(fd);
              // 把连接从连接队列清除
              pop(fd);
              // 通知系统连接断开
              // on_disconnect通常需要进行数据库和日志操作
              on_disconnect(fd);
         }
     }
}


// 连接上有可接收的数据
if (is_read(fd))
{
     // 接收等差数列尾数
     int n = recv(fd);
     // 调用处理函数
     int m = proc_data(n);
     // 回复计算结果到客户端
     send(fd, m);
}
// 处理等差数列计算
int proc_data(int n)
{
     // 计算等差数列
     int m = 0;
     for (int i = 1;i <= n;i ++)
     {
         m += i;
     }
     // 把M写入数据库
     db_query(m);
     // 把M写入日志
     log(m);
     // 返回
     return m;
}


// 连接上有可接收的数据
if (is_read(fd))
{
     // 触发线程执行
     trigger_thread(fd, thread_proc);
}
// 线程处理函数
void thread_proc(fd)
{
     // 接收等差数列尾数
     int N = recv(fd);
     // 调用处理函数
     int E = proc_data(N);
     // 回复计算结果到客户端
     send(fd, E);
}
// 处理等差数列计算
int proc_data(int N)
{
     // 计算等差数列
     int M = 0;
     for (int i = 1;i <= N;i ++)
     {
         M += i;
     }
     // 把M写入数据库
     db_query(M);
     // 把M写入日志
     log(M);
     // 返回
     return M;
}


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

// 监听线程
void listen_thread()
{
     // IOCP对象
     HANDLE iocp;
     // 监听套接字
     int lsfd;
     // 用户对象指针
     void * ptr;
     while (true)
     {
         // 接收新的连接
         int fd = accept(lsfd);
         // 放入iocp队列
         iocp_push(iocp, fd, ptr);
     }
}
// 请求处理线程
void proc_thread()
{
     // IOCP对象
     HANDLE iocp;
     // 连接套接字
     int fd;
     // 用户对象
     void * ptr;
     // 接收的数据
     char * data;
     while (iocp_event(&fd, & ptr))
     {
         // 如果是连接事件
         if (is_connect(fd))
         {
              // 通知系统要接收数据
              // 这个过程不阻塞，下次接收完毕会通知
              trigger_recv(iocp, data);
         }
         // 如果是接收到数据的事件
         else if (is_recved(fd, &data))
         {
              // 处理接收的数据
              proc_data(data, ptr);
              // 回复处理结果
              send(data);
         }
         // 如果是断开事件
         else if (is_disconnect(fd))
         {
         }
     }
}