0

我的管道工作有些困难。我有以下代码：

/* Set security attributes */
sa.nLength = sizeof(SECURITY_ATTRIBUTES);
sa.bInheritHandle = TRUE; 
sa.lpSecurityDescriptor = NULL; 

if (CreatePipe(&Rread, &Rwrite, &sa, 0) == 0 || SetHandleInformation(Rread, HANDLE_FLAG_INHERIT, 0) == 0 || CreatePipe(&Wread, &Wwrite, &sa, 0) == 0 || SetHandleInformation(Wwrite, HANDLE_FLAG_INHERIT, 0) == 0)
{
    /* Error */
}


/* Set process information */
si.dwFlags = STARTF_USESTDHANDLES;
si.hStdOutput = Rwrite;
si.hStdError = Rwrite;


if (CreateProcess(NULL, argsCasted->cmd, NULL, NULL, TRUE, CREATE_NO_WINDOW, NULL, NULL, &si, &pi) == 0)
{
    /* Error */
}


for (;;)
{
    PeekNamedPipe(Rread, NULL, 0, &a, NULL, NULL);

    if (a > 0)
    {
        /* Write output somewhere... */
    }

    if (a == 0 && GetExitCodeProcess(pi.hProcess, &c) != 0 && c != STILL_ACTIVE) break;

    Sleep(50);
}


    /* CloseHandles... */

    /* Free stuff... */

现在，当我添加si.hStdInput = Wread;（以便我可以向进程发送输入）时，PeekNamedPipe()阻塞。

我简化了很多代码，因为它是大型多线程应用程序的一部分，太大了，无法在此处发布。如果有人需要我提供更多详细信息来解决此问题，请在此处发布，我将添加所需的详细信息。

提前感谢乔里。

4

1 回答 1

1

PeekNamedPipe如果管道中没有要读取的数据，将阻塞。您将不得不使用异步/非阻塞 I/O。

参考：异步IO

于 2012-08-16T10:03:19.517 回答