subprocess上重叠的ReadFileEx'redirect标准输出不会触发

我有一个长期运行的基于控制台的应用程序发件人，它使用非缓冲输出（如cout <<“Message”<< flush（））将简单文本发送到STDOUT。 我想创build一个基于MFC对话框的应用程序（名为Receiver）启动发件人并可以读取它的输出。 接收者也应该能够检测到发送者已经死亡，或者如果愿意的话可以杀死发送者。 发件人对Reciever一无所知，我不能改变发件人的代码。

我已经问了一个单独的问题 ，最好的方法来做到这一点。 我的第一个尝试是创buildpipe道redirectSTDIN和STDOUT的subprocess，并使用asynchronousReadFileEx调用来读取发件人的数据。 这是不正常工作的，因为ReadFileEx函数只会触发一次，只有传输零字节，即使我知道Sender正在发送数据的事实。

我正在创build2个redirectSTDIN和STDOUT的pipe道，ala 这个MS示例 ：

 // allow the child process to inherit handles SECURITY_ATTRIBUTES sa = {0}; sa.nLength = sizeof(sa); sa.bInheritHandle = 1; // create pipes with rerouted stdin & stdout CreatePipe(&handles[h_Child_StdOut_Read], &handles[h_Child_StdOut_Write], &sa, 0); SetHandleInformation(handles[h_Child_StdOut_Read], HANDLE_FLAG_INHERIT, 0); CreatePipe(&handles[h_Child_StdIn_Read], &handles[h_Child_StdIn_Write], &sa, 0); SetHandleInformation(handles[h_Child_StdIn_Read], HANDLE_FLAG_INHERIT, 0); 

… Receiver然后继续通过CreateProcess（）启动Sender ：

 // create child process PROCESS_INFORMATION pi = {0}; STARTUPINFO si = {0}; si.cb = sizeof(si); si.hStdOutput = handles[h_Child_StdOut_Write]; si.hStdInput = handles[h_Child_StdIn_Read]; si.dwFlags |= STARTF_USESTDHANDLES; CreateProcess( 0, "Sender.EXE", 0, 0, 1, 0, 0, 0, &si, &pi); handles[h_Child_Process] = pi.hProcess; handles[h_Child_Thread] = pi.hThread; 

我的主循环是基于WaitForObjectsEx，放置在一个可警告的等待状态，以支持读取asynchronous文件。 我在等待两个句柄：一个是Sender过早死亡的信号，另一个是Receiver的主线程要Sender者死亡的信号。 在开始循环之前，我在Sender者的STDOUT上启动一个重叠的（asynchronous）文件读取操作。 忽略明显的内存泄漏和其他黑客 – 这是说明性的：

 vector<HANDLE> wait_handles; wait_handles.push_back(handles[h_Die_Sig]); wait_handles.push_back(handles[h_Child_Process]); for( bool cont = true; cont; ) { IO* io = new IO; memset(io, 0, sizeof(IO)); io->buf_size_ = 16 * 1024; io->buf_ = new char[io->buf_size_]; memset(io->buf_, 0, io->buf_size_); io->thread_ = &param; io->file_ = handles[h_Child_StdOut_Read]; if( !ReadFileEx(io->file_, io->buf_, io->buf_size_, io, OnFileRead) ) { DWORD err = GetLastError(); string err_msg = util::strprintwinerr(err); } DWORD rc = WaitForMultipleObjectsEx(wait_handles.size(), &wait_handles[0], FALSE, INFINITE, TRUE); // ... } 

上面的IO对象是从OVERLAPPED公开派生的：

 struct IO : public OVERLAPPED { char* buf_; DWORD buf_size_; DWORD read_; ThreadParam* thread_; HANDLE file_; }; 

当重叠的Read函数完成时，我读取传入的数据并生成一个string：

 void CALLBACK OnFileRead(DWORD err, DWORD bytes, OVERLAPPED* ovr) { IO* io = static_cast<IO*>(ovr); string msg(io->buf_, bytes); } 

Sender对Receiver一无所知，它使用非常简单的但不缓冲的方式将文本发送到控制台。

问题：我知道Sender正在向其STDOUT发送数据，但是我的OnFileRead函数只被调用一次，并且只传输零字节。

为什么我不能以这种方式接收Sender的输出？ 我有一个错误，或者我做错了什么？

 CreatePipe(&handles[h_Child_StdOut_Read], &handles[h_Child_StdOut_Write], &sa, 0); SetHandleInformation(handles[h_Child_StdOut_Read], HANDLE_FLAG_INHERIT, 0); CreatePipe(&handles[h_Child_StdIn_Read], &handles[h_Child_StdIn_Write], &sa, 0); SetHandleInformation(handles[h_Child_StdIn_Read], HANDLE_FLAG_INHERIT, 0); 

 SetHandleInformation(handles[h_Child_StdIn_Write], HANDLE_FLAG_INHERIT, 0);