0

我正在尝试学习异步 I/O。
我的程序创建套接字并使用 AcceptEx 接受它们或使用 connect 连接它们。在其主线程中，我在循环中调用 WaitForMultipleObjects()，但我仍然创建线程来解析名称，调用 connect() 并调用初始 ReadFile()。
这些线程在调用 ReadFile() 后退出，让主线程等待读取结果。

由于某种原因，在连接线程死亡后，读取操作被取消，事件被触发，GetOverlappedResult() 失败并出现 ERROR_OPERATION_ABORTED

例子：

#define _WIN32_WINNT 0x0501

#include <winsock2.h>
#include <ws2tcpip.h>
#include <wspiapi.h>
#include <windows.h>

#include <stdio.h>
#include <tchar.h>


#define BUFSZ 2048

#define PORT 80
#define HOST "192.168.2.1"
#define HOST "stackoverflow.com"

static struct {
    char buf[BUFSZ];
    OVERLAPPED overlap;
    SOCKET sock;
} x = { 0 };

static DWORD WINAPI barthread(LPVOID param) {
    static struct sockaddr_in inaddr = { 0 };
    int rc;
    BOOL b;
    DWORD dw;
    DWORD nb;
    LPHOSTENT lphost;

    x.sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    inaddr.sin_family = AF_INET;

    lphost = gethostbyname(HOST);
    inaddr.sin_addr.s_addr = ((LPIN_ADDR)lphost->h_addr)->s_addr;
    inaddr.sin_port = htons(PORT);

    rc = connect(x.sock, (struct sockaddr *)&inaddr, sizeof(struct sockaddr_in));

    if (rc == 0) {
        printf("thread 2 connected\n");
        printf("thread 2 call ReadFile\n");
        b = ReadFile((HANDLE)x.sock, x.buf, BUFSZ, &nb, &x.overlap);
        dw = GetLastError();
        if (b || dw == ERROR_IO_PENDING) {
            printf("thread 2 ReadFile ok\n");
        } else {
            printf("thread 2 ReadFile failed\n");
        }
        printf("thread 2 sleeping\n");
        Sleep(3000);
        printf("thread 2 dying\n");
    }
    return 0;
}

int main(int argc, char* argv[])
{
    WSADATA WD;

    BOOL b;
    DWORD dw;
    DWORD nb;
    DWORD tid;

    WSAStartup(MAKEWORD(2, 0), &WD);

    x.overlap.hEvent = CreateEvent(NULL, FALSE, FALSE, NULL);
    CreateThread(NULL, 0, barthread, NULL, 0, &tid);

    dw = WaitForSingleObject(x.overlap.hEvent, INFINITE);
    printf("thread 1 event triggered\n");
    b = GetOverlappedResult((HANDLE)x.sock, &x.overlap, &nb, FALSE);
    dw = GetLastError();
    printf("thread 1 GetOverlappedResult() = %d, GetLastError() = %d\n", b, dw);

    return 0;
}
4

2 回答 2

2

您根本不应该使用单独的线程。重叠 I/O 的全部意义在于单个线程可以同时执行多个任务。让您的主循环使用WSAAsyncGetHostByName()而不是gethostbyname()，并WSAConnect()在非阻塞模式下使用WSAEventSelect()而不是connect()在阻塞模式下。

于 2013-09-01T21:54:41.247 回答
0

在这里找到了类似的问题： 异步套接字读取：不能退出启动线程 - 怎么办？
并且，在这里： http: //www.boost.org/doc/libs/1_39_0/doc/html/boost_asio/reference/asynchronous_operations.html ：

具体来说，在 Vista 之前的 Windows 版本中，未完成的操作会在启动线程退出时被取消。

我有 Windows 7，但遇到同样的问题。

我不会在临时线程中调用初始的 ReadFile()，而是设置一些标志，手动设置事件并在主循环中调用 ReadFile()。

于 2013-09-01T18:42:34.033 回答