0

我写了下面的代码。我正在调用此方法以使用三个单独的线程写入三个不同的硬盘。CancelIo 调用之一失败（返回 false）。

我假设磁盘没问题（硬件没问题）。

怎么会这样？

（更换磁盘后，我看到它在另一个磁盘上再次发生。） 

  public void foo(byte[] bufferToWrite)
  {
      unsafe
      {

            NativeOverlapped overlapped = new NativeOverlapped()
            {
                  EventHandle = eventHandle,
                  OffsetLow   = ( int )( s       & 0xffffffff ),
                  OffsetHigh  = ( int )( s >> 32 & 0xffffffff )
            };

            GCHandle gch = GCHandle.Alloc( bufferToWrite, GCHandleType.Pinned );
            IntPtr ptr = new IntPtr( ( void* )gch.AddrOfPinnedObject() );

            WriteFile( handle, ptr, length, ref bytesWritten, &overlapped );

            dwResult = WaitForSingleObject( EventHandle, 30000 );
            if(dwResult== TIME_OUT)
            {
                   Debug.Assert( CancelIo ( handle ) );

            }
      }
  }
4

1 回答 1

2

如果没有未完成的 IO，CancelIo 会失败。您的 IO 可能会在 30001 毫秒后完成，就在事件等待以超时结束之后。

这种竞争条件无法修复。我知道没有比忽略返回值更好的解决方案了。

于 2012-05-03T21:47:30.173 回答