问题的起因：
  大概的例子就是这样     为什么只创建2个线程来处理用户信息？在while循环里WSAAccept的时候要是有1000个用户都连进来了     那么2个线程够处理吗？  
    
  另外   不是听说IOCP是管理线程池的吗     一运行一个IOCP，系统就建1000好几百个线程sleep着，   然后有客户连进来就抓来一个线程让他醒过来为客户服务     客户用完以后再把回到线程池里而不关掉  
    
  可是我左找右找只找到了2个线程     那1000好几百个线程到哪里去了？  

void   main(void)           {             WSAStartup(0x0202,   &wsaData));             CompletionPort   =   CreateIoCompletionPort(INVALID_HANDLE_VALUE,   NULL,   0,   0))   ==   NULL);                    for(i   =   0;   i   <   SystemInfo.dwNumberOfProcessors   *   2;   i++)             {               HANDLE   ThreadHandle;                    ThreadHandle   =   CreateThread(NULL,   0,   ServerWorkerThread,   CompletionPort,                 0,   &ThreadID));               CloseHandle(ThreadHandle);             }             ......                //   开始创建监听Socket...             while(TRUE)             {                       WSAAccept(Listen,   NULL,   NULL,   NULL,   0);                     .....                     .....             }                    
    
  ==================================================  
  大概的例子就是这样     为什么只创建2个线程来处理用户信息？在while循环里WSAAccept的时候要是有1000个用户都连进来了     那么2个线程够处理吗？  
    
  另外   不是听说IOCP是管理线程池的吗     一运行一个IOCP，系统就建1000好几百个线程sleep着，   然后有客户连进来就抓来一个线程让他醒过来为客户服务     客户用完以后再把回到线程池里而不关掉  
    
  可是我左找右找只找到了2个线程     那1000好几百个线程到哪里去了？  

相关重要讨论信息：

jiangsheng（蒋晟.Net[MVP]）



wqrz_013（）


DentistryDoctor（不在无聊中无奈，就在沉默中变态）



kugou123（酷狗)(彪悍的人生，不需要解释 www.xiaozhou.net）


sevencat（七猫）

我来把他的实现贴一下吧。  
  VOID     KeInitializeQueue   (             IN   PRKQUEUE   Queue,             IN   ULONG   Count   OPTIONAL             )          /*++          Routine   Description:                  This   function   initializes   a   kernel   queue   object.          Arguments:                  Queue   -   Supplies   a   pointer   to   a   dispatcher   object   of   type   event.                  Count   -   Supplies   the   target   maximum   number   of   threads   that   should                     be   concurrently   active.   If   this   parameter   is   not   specified,                     then   the   number   of   processors   is   used.          Return   Value:                  None.          --*/          {                  //             //   Initialize   standard   dispatcher   object   header   and   set   initial             //   state   of   queue   object.             //                  Queue->Header.Type   =   QueueObject;             Queue->Header.Size   =   sizeof(KQUEUE)   /   sizeof(LONG);             Queue->Header.SignalState   =   0;             InitializeListHead(&Queue->Header.WaitListHead);                  //             //   Initialize   queue   listhead,   the   thread   list   head,   the   current   number             //   of   threads,   and   the   target   maximum   number   of   threads.             //                  InitializeListHead(&Queue->EntryListHead);             InitializeListHead(&Queue->ThreadListHead);             Queue->CurrentCount   =   0;             if   (ARGUMENT_PRESENT((PVOID)(ULONG_PTR)Count))   {                     Queue->MaximumCount   =   Count;                  }   else   {                     Queue->MaximumCount   =   KeNumberProcessors;             }                  return;     }          LONG     KeReadStateQueue   (             IN   PRKQUEUE   Queue             )          /*++          Routine   Description:                  This   function   reads   the   current   signal   state   of   a   Queue   object.          Arguments:                  Queue   -   Supplies   a   pointer   to   a   dispatcher   object   of   type   Queue.          Return   Value:                  The   current   signal   state   of   the   Queue   object.          --*/          {                  ASSERT_QUEUE(Queue);                  //             //   Return   current   signal   state   of   Queue   object.             //                  return   Queue->Header.SignalState;     }          LONG     KeInsertQueue   (             IN   PRKQUEUE   Queue,             IN   PLIST_ENTRY   Entry             )          /*++          Routine   Description:                  This   function   inserts   the   specified   entry   in   the   queue   object   entry             list   and   attempts   to   satisfy   the   wait   of   a   single   waiter.                  N.B.   The   wait   discipline   for   Queue   object   is   LIFO.          Arguments:                  Queue   -   Supplies   a   pointer   to   a   dispatcher   object   of   type   Queue.                  Entry   -   Supplies   a   pointer   to   a   list   entry   that   is   inserted   in   the                     queue   object   entry   list.          Return   Value:                  The   previous   signal   state   of   the   Queue   object.          --*/          {                  KIRQL   OldIrql;             LONG   OldState;                  ASSERT_QUEUE(Queue);             ASSERT(KeGetCurrentIrql()   <=   DISPATCH_LEVEL);                  //             //   Raise   IRQL   to   dispatcher   level   and   lock   dispatcher   database.             //                  KiLockDispatcherDatabase(&OldIrql);                  //             //   Insert   the   specified   entry   in   the   queue   object   entry   list.             //                  OldState   =   KiInsertQueue(Queue,   Entry,   FALSE);                  //             //   Unlock   the   dispather   database,   lower   IRQL   to   the   previous   level,   and             //   return   signal   state   of   Queue   object.             //                  KiUnlockDispatcherDatabase(OldIrql);             return   OldState;     }


baodi_z（冷冷的太阳）



coolFly19（）


sevencat（七猫）


lzzqqq（Jonersen）


shootingstars（有容乃大，无欲则刚）


sevencat（七猫）
level1979（岳麓飘湘）


IO2（ G*道也）