線程池的編碼實現[1]

線程池的編碼實現[1]  軟件測試工具

關鍵字：數據庫設計下面以一個簡單的服務器為例來實現上述算法。假設客戶端向服務器發送一個“Hello!”字符串，服務器收到后判斷一下是不是“Hello!”這個字符串，如果是則發回一個“OK”字符串給客戶端。

   下面給出線程池調度管理的編碼實現。
    #define  MAX_QUEUE_SIZE       4 096
    #define  MAX_LISTEN_SIZE       16
    #define  MAX_THREADS            10
    #define  DEFAULT_PORT           8 080
    MSGQUEUE    *g_pQue；
    void ProcessRequest(void *args)；
    /**   初始化函數，初始化時會先創建消息隊列，并預創建MAX_THREADS個線程
            @return  INT——返回CAPI_FAILED表示失??；返回CAPI_SUCCESS表示成功
    */
    INT Init()
    {
            INT i；
            g_pQue = MsgQueue_Create(MAX_QUEUE_SIZE)；
            if ( g_pQue == NULL )
            {
                   return CAPI_FAILED；
            }
            for ( i = 0；i < MAX_THREADS；i++ )
            {
                   _beginthread(ProcessRequest, 0, NULL)；
            }
            return CAPI_SUCCESS；
    }
    /**   接收請求的處理函數，實現將接收請求的SOCKET標識符放入到消息隊列中
            @return  INT——返回CAPI_FAILED表示失??；返回CAPI_SUCCESS表示成功
    */
    INT RecvQuest()
    {
            struct sockaddr_in local, from；
            SOCKET s, msgsock；
            int fromlen；
            s = socket(AF_INET, SOCK_STREAM, 0)；
            if (s ==  INVALID_SOCKET)
            {
                   return CAPI_FAILED；
            }
            local.sin_family = AF_INET；
            local.sin_addr.s_addr = INADDR_ANY；
            local.sin_port = htons(DEFAULT_PORT)；
            if ( bind(s, (struct sockaddr*)&local, sizeof(local)) == SOCKET_ERROR)
            {
                   return CAPI_FAILED；
            }
            if ( listen(s, MAX_LISTEN_SIZE ) == SOCKET_ERROR)
            {
                   return CAPI_FAILED；
            }
            while( msgsock = aclearcase/" target="_blank" >ccept(s, (struct sockaddr*)&from, &fromlen)
                   != INVALID_SOCKET )
            {
                   SOCKET *pNewSock = new SOCKET；
                   *pNewSock = msgsock；
                   /* 事實上可放更多信息到消息隊列中，這里放一個SOCK ID示意一下 */
                    MsgQueue_Send(g_pQue, (void *)pNewSock)；
            }
            return CAPI_SUCCESS；
    }
    /**   處理請求的任務處理函數，這個函數是處理任務的入口函數，在里面處理接收客戶端
            發來的字符串“Hello!”并發送響應“OK”到客戶端

原文轉自：http://www.kjueaiud.com