完成端口(IOCP) 也可以這樣用~~呵呵~ 用來充當線程之間的資料隊列~

// Test32.cpp : 定義控制台應用程式的入口點。

//

#include "stdafx.h"

#include <stdlib.h>

#include <windows.h>

#include <process.h>

#include <iostream>

HANDLE m_hCompletionPort;

volatile BOOL m_bShutDown;

struct TESTOVERLAPPED

{

    OVERLAPPED    m_ol;

    CHAR        szData[512];

};

UINT WINAPI IOWorkerThreadProc(LPVOID pParam)

    BOOL            bError            = FALSE;

    DWORD            dwIoSize        = 0;

    DWORD            dwCmpKey        = 0;

    LPOVERLAPPED    lpOverlapped    = NULL;

    TESTOVERLAPPED*    pOverlapBuff    = NULL;

    while ( !bError )

    {

        pOverlapBuff        = NULL;

        dwCmpKey = 0;

        // Get a completed IO request.

        BOOL bIORet = GetQueuedCompletionStatus(m_hCompletionPort, &dwIoSize, (LPDWORD) &dwCmpKey, &lpOverlapped, INFINITE);

        // Simulate workload (for debugging, to find possible reordering)

        //Sleep(20);

        // If Something whent wrong..

        if (!bIORet)  

        {

            DWORD dwIOError = GetLastError();

            if(dwIOError != WAIT_TIMEOUT) // It was not an Time out event we wait for ever (INFINITE) 

            {    

                    continue;

            }

        }// if (!bIORet) 

        if(bIORet && lpOverlapped && dwCmpKey) 

            pOverlapBuff=CONTAINING_RECORD(lpOverlapped, TESTOVERLAPPED, m_ol);

            if(pOverlapBuff!=NULL)

            {

                //pThis->ProcessIOMessage(pOverlapBuff, dwCmpKey, dwIoSize);

                printf("ThreaId：0x%x %d %s ",GetCurrentThreadId(),dwCmpKey,pOverlapBuff->szData);

            delete pOverlapBuff;

        }    

        if((dwCmpKey == NULL) && (pOverlapBuff == NULL) && m_bShutDown)

            bError = TRUE;

        }

    } 

    printf("Thread dead!");

    return 0xdead;

}

int _tmain(int argc, _TCHAR* argv[])

    m_hCompletionPort = CreateIoCompletionPort( INVALID_HANDLE_VALUE, NULL, 0, 0 );

    uintptr_t hThread =_beginthreadex(0,0,IOWorkerThreadProc, 0,0, NULL);

    hThread =_beginthreadex(0,0,IOWorkerThreadProc, 0,0, NULL);

    m_bShutDown = FALSE;

    for(int i = 0; i < 30; i++)

        DWORD dwCmpKey = i;

        TESTOVERLAPPED * pOverlapBuff = new TESTOVERLAPPED;

        memset(pOverlapBuff->szData,0,sizeof(pOverlapBuff->szData));

        sprintf(pOverlapBuff->szData,"CMD ID：%d",i);

        PostQueuedCompletionStatus(m_hCompletionPort, 0, (ULONG_PTR) &dwCmpKey, &pOverlapBuff->m_ol);

    }

    m_bShutDown = TRUE;

    PostQueuedCompletionStatus(m_hCompletionPort,0,0,0);

    getchar();

    return 0;