我想实时监视一个线程中多个目录的更改,因此我决定与GetQueuedCompletionStatus异步使用ReadDirectoryChangesW()方法。这是我的代码:
static DWORD WINAPI Routine( LPVOID lParam )
{
FileSystemWatcher* obj = (FileSystemWatcher*)lParam;
obj->hDir[0] = CreateFile(
obj->WatchedDir[0].c_str(),
GENERIC_READ|GENERIC_WRITE,
FILE_SHARE_READ|FILE_SHARE_WRITE|FILE_SHARE_DELETE,
NULL,
OPEN_EXISTING,
FILE_FLAG_BACKUP_SEMANTICS|FILE_FLAG_OVERLAPPED,
NULL
);
obj->hDir[1] = CreateFile(
obj->WatchedDir[1].c_str(),
GENERIC_READ|GENERIC_WRITE,
FILE_SHARE_READ|FILE_SHARE_WRITE|FILE_SHARE_DELETE,
NULL,
OPEN_EXISTING,
FILE_FLAG_BACKUP_SEMANTICS|FILE_FLAG_OVERLAPPED,
NULL
);
if( INVALID_HANDLE_VALUE == obj->hDir[0] || INVALID_HANDLE_VALUE == obj->hDir [1] )
{
return false;
}
obj->IOCPHandle[0] = CreateIoCompletionPort(obj->hDir[0], NULL, 0, 1);
obj->IOCPHandle[1] = CreateIoCompletionPort(obj->hDir[1], NULL, 0, 1);
if (obj->IOCPHandle[0] == INVALID_HANDLE_VALUE || obj->IOCPHandle[1] == INVALID_HANDLE_VALUE)
{
return false;
}
char buf[ 2*(sizeof(FILE_NOTIFY_INFORMATION)+MAX_PATH) ];
FILE_NOTIFY_INFORMATION* pNotify=(FILE_NOTIFY_INFORMATION *)buf;
DWORD BytesReturned;
LPOVERLAPPED overLap = NULL;
m_pFileNotifyInfo = pNotify;
dirEvents[0] = CreateEvent(NULL, TRUE, FALSE, NULL);
dirEvents[1] = CreateEvent(NULL, TRUE, FALSE, NULL);*/
while(true)
{
BOOL success = ReadDirectoryChangesW( obj->hDir[0],
pNotify,
sizeof(buf),
true,
FILE_NOTIFY_CHANGE_FILE_NAME|FILE_NOTIFY_CHANGE_DIR_NAME,
&BytesReturned,
overLap,
NULL );
BOOL success1 = ReadDirectoryChangesW( obj->hDir[1],
pNotify,
sizeof(buf),
true,
FILE_NOTIFY_CHANGE_FILE_NAME|FILE_NOTIFY_CHANGE_DIR_NAME,
&BytesReturned,
overLap,
NULL );
LPOVERLAPPED theOverLap;
PULONG_PTR lpCompKey = NULL;
if (GetQueuedCompletionStatus(obj->IOCPHandle[0], &BytesReturned, lpCompKey, &overLap, 100))
{
cout<<"First Dir Changed"<<endl;
}
if (GetQueuedCompletionStatus(obj->IOCPHandle[1], &BytesReturned, lpCompKey, &overLap, 100))
{
cout<<"Second Dir Changed"<<endl;
}
cout<<"Nothing happened yet"<<endl;
}
return 0;
}
在这里,当我运行代码时,无论我为GetQueuedCompletionStatus()函数的最后一个参数设置什么值,线程都会无缘无故地阻塞。我不知道为什么会遇到这个问题。谁能告诉我原因?非常感谢!
最佳答案
LPOVERLAPPED overLap = NULL;
)。 hEvent
并在这些事件上执行WaitForMultipleObjects
。 关于c++ - 异步使用ReadDirectoryChangesW时的线程死锁,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/343099/