草庐IT

windows - 如何判断 ReadFileEx() 重叠 I/O 何时完成？

coder 2024-06-12 原文

HasOverlappedIoCompleted()不适用于以 ReadFileEx() 开头的异步 I/O和 WriteFileEx() .底部的代码片段演示了这一点。在此示例中，ReadFileEx() 从没有输入的管道中读取数据，因此读取不会完成。但是 HasOverlappedIoCompleted() 返回 TRUE。如果我将调用更改为重叠的 ReadFile()，则 HasOverlappedIoCompleted() 会按预期返回 FALSE。

我的问题是:如何在不依赖回调本身的情况下，找出带有回调的重叠 I/O 请求是否已完成？在我的应用程序中，APC 可能已经排队，但不一定已经运行，因为应用程序可能尚未处于可警报状态。

谢谢。

(注意 GetOverlappedResult() 没有帮助 - 它也返回 TRUE。)

更多背景知识:在示例中，我使用了 ReadFileEx()，因为它很容易演示问题。在我的应用程序中，我在管道实例上重复调用 WriteFileEx()。如果之前的 WriteFileEx() 尚未完成，我必须丢弃消息而不是发送消息(我不能在同一个管道实例上有多个待处理的写入)，但是如果前一个 WriteFileEx() 已经 完成，那么我必须开始下一个，即使完成回调还没有运行.

编辑:问题场景的描述

  1. 线程进入可警报状态(有一个读取 APC 排队)。
  2. 读取 APC 开始:它对 WriteFileEx() 进行排队并设置“写入挂起”标志。然后它将 ReadFileEx() 排队。
  3. 主线程开始工作(不可警报)。
  4. 排队的读取完成。
  5. 排队的写入完成(在读取之后)。
  6. 主线程进入警报状态。
  7. 读取的 APC 在队列中排在第一位，因此首先运行:它查看“写入挂起”标志，因为它仍处于设置状态，所以它会丢弃写入。事实上，虽然 WriteFileEx() 已经 完成，但它还没有调用它的 APC，因为 ReadFileEx() 先完成了。

我不想测试我自定义的“写入挂起”标志，而是想从操作系统中找出 WriteFileEx() 是否已实际完成，即使 APC 尚未运行也是如此。

#include <Windows.h>
#include <stdio.h>
#include <assert.h>

VOID CALLBACK readComplete(DWORD err, DWORD bytes, LPOVERLAPPED ovlp)
{
}

int main(int argc, char *argv[])
{
  HANDLE     hServer;
  OVERLAPPED serverOvlp = { 0 };
  HANDLE     hClient;
  DWORD      bytes;
  BYTE       buffer[16];
  BOOL       result;

  hServer = CreateNamedPipe("\\\\.\\pipe\\testpipe", PIPE_ACCESS_DUPLEX | FILE_FLAG_OVERLAPPED,
                            PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_WAIT, 
                            PIPE_UNLIMITED_INSTANCES, 0, 0, 5000, NULL);

  serverOvlp.hEvent = CreateEvent(NULL, FALSE, FALSE, NULL);

  ConnectNamedPipe(hServer, &serverOvlp);
  assert(GetLastError() == ERROR_IO_PENDING);

  hClient = CreateFile("\\\\.\\pipe\\testpipe", GENERIC_READ | GENERIC_WRITE,
                       0, NULL, OPEN_EXISTING, 0, NULL);

  GetOverlappedResult(hServer, &serverOvlp, &bytes, TRUE);

  /* Server starts an overlapped read */
//  result = ReadFile(hServer, buffer, sizeof(buffer), &bytes, &serverOvlp);
  result = ReadFileEx(hServer, buffer, sizeof(buffer), &serverOvlp, readComplete);

  if (HasOverlappedIoCompleted(&serverOvlp))
  {
    puts("Completed");
  }
  else
  {
    puts("Not completed");
  }


  return EXIT_SUCCESS;
}

最佳答案

你要求的行为对我来说似乎是错误的，因为它涉及竞争条件。仅当您仍在发送消息 B 时收到消息 A 时才会出现此问题。目前，A 始终被忽略，即不发送其他消息。当且仅当服务器在 A 到达和 B 完成之间的时间间隔内忙于处理工作时，您尝试获得的行为才会导致发送额外的消息。我认为您应该始终忽略 A，或者始终在 B 完成后发送响应。

但是，如果您确定这是您想要的，则可以实现此行为。一种解决方案是从 ReadFileEx 完成例程调用 QueueUserAPC，将对发送回复的函数的调用排队。由于APC是按照先进先出的顺序运行的，新的APC肯定会在WriteFileEx已经排队的APC之后运行。

根据细节，设置标志或将项目添加到队列并让您的主循环执行实际工作的两个完成例程可能更清晰。

如果您需要轮询 APC(例如，因为您的主循环没有任何自然发生的等待操作)，您可以在超时为 0 的虚拟事件上使用 WaitForSingleObjectEx。事件是否发生并不重要无论是否发出信号，所有排队的 APC 仍将被调用。

关于windows - 如何判断 ReadFileEx() 重叠 I/O 何时完成？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/8387070/

ReadFileEx何时codeWriteFileExwindowswinapioverlapped-io

有关windows - 如何判断 ReadFileEx() 重叠 I/O 何时完成？的更多相关文章

  1. ruby - 如何使用 Nokogiri 的 xpath 和 at_xpath 方法 - 2

    我正在学习如何使用Nokogiri，根据这段代码我遇到了一些问题:require'rubygems'require'mechanize'post_agent=WWW::Mechanize.newpost_page=post_agent.get('http://www.vbulletin.org/forum/showthread.php?t=230708')puts"\nabsolutepathwithtbodygivesnil"putspost_page.parser.xpath('/html/body/div/div/div/div/div/table/tbody/tr/td/div

  2. ruby - 如何从 ruby​​ 中的字符串运行任意对象方法？ - 2

    总的来说，我对ruby​​还比较陌生，我正在为我正在创建的对象编写一些rspec测试用例。许多测试用例都非常基础，我只是想确保正确填充和返回值。我想知道是否有办法使用循环结构来执行此操作。不必为我要测试的每个方法都设置一个assertEquals。例如:describeitem,"TestingtheItem"doit"willhaveanullvaluetostart"doitem=Item.new#HereIcoulddotheitem.name.shouldbe_nil#thenIcoulddoitem.category.shouldbe_nilendend但我想要一些方法来使用

  3. ruby - 在 Ruby 程序执行时阻止 Windows 7 PC 进入休眠状态 - 2

    我需要在客户计算机上运行Ruby应用程序。通常需要几天才能完成(复制大备份文件)。问题是如果启用sleep，它会中断应用程序。否则，计算机将持续运行数周，直到我下次访问为止。有什么方法可以防止执行期间休眠并让Windows在执行后休眠吗？欢迎任何疯狂的想法;-) 最佳答案 Here建议使用SetThreadExecutionStateWinAPI函数，使应用程序能够通知系统它正在使用中，从而防止系统在应用程序运行时进入休眠状态或关闭显示。像这样的东西:require'Win32API'ES_AWAYMODE_REQUIRED=0x0

  4. python - 如何使用 Ruby 或 Python 创建一系列高音调和低音调的蜂鸣声？ - 2

    关闭。这个问题是opinion-based.它目前不接受答案。想要改进这个问题？更新问题，以便editingthispost可以用事实和引用来回答它.关闭4年前。Improvethisquestion我想在固定时间创建一系列低音和高音调的哔哔声。例如:在150毫秒时发出高音调的蜂鸣声在151毫秒时发出低音调的蜂鸣声200毫秒时发出低音调的蜂鸣声250毫秒的高音调蜂鸣声有没有办法在Ruby或Python中做到这一点？我真的不在乎输出编码是什么(.wav、.mp3、.ogg等等)，但我确实想创建一个输出文件。

  5. ruby-on-rails - 如何验证 update_all 是否实际在 Rails 中更新 - 2

    给定这段代码defcreate@upgrades=User.update_all(["role=?","upgraded"],:id=>params[:upgrade])redirect_toadmin_upgrades_path,:notice=>"Successfullyupgradeduser."end我如何在该操作中实际验证它们是否已保存或未重定向到适当的页面和消息？ 最佳答案 在Rails3中，update_all不返回任何有意义的信息，除了已更新的记录数(这可能取决于您的DBMS是否返回该信息)。http://ar.ru

  6. ruby-on-rails - 'compass watch' 是如何工作的/它是如何与 rails 一起使用的 - 2

    我在我的项目目录中完成了compasscreate.和compassinitrails。几个问题:我已将我的.sass文件放在public/stylesheets中。这是放置它们的正确位置吗？当我运行compasswatch时，它不会自动编译这些.sass文件。我必须手动指定文件:compasswatchpublic/stylesheets/myfile.sass等。如何让它自动运行？文件ie.css、print.css和screen.css已放在stylesheets/compiled。如何在编译后不让它们重新出现的情况下删除它们？我自己编译的.sass文件编译成compiled/t

  7. ruby - 如何将脚本文件的末尾读取为数据文件(Perl 或任何其他语言) - 2

    我正在寻找执行以下操作的正确语法(在Perl、Shell或Ruby中):#variabletoaccessthedatalinesappendedasafileEND_OF_SCRIPT_MARKERrawdatastartshereanditcontinues. 最佳答案 Perl用__DATA__做这个:#!/usr/bin/perlusestrict;usewarnings;while(){print;}__DATA__Texttoprintgoeshere 关于ruby-如何将脚

  8. ruby - 如何指定 Rack 处理程序 - 2

    Rackup通过Rack的默认处理程序成功运行任何Rack应用程序。例如:classRackAppdefcall(environment)['200',{'Content-Type'=>'text/html'},["Helloworld"]]endendrunRackApp.new但是当最后一行更改为使用Rack的内置CGI处理程序时，rackup给出“NoMethodErrorat/undefinedmethod`call'fornil:NilClass”:Rack::Handler::CGI.runRackApp.newRack的其他内置处理程序也提出了同样的反对意见。例如Rack

  9. ruby - 如何每月在 Heroku 运行一次 Scheduler 插件？ - 2

    在选择我想要运行操作的频率时，唯一的选项是“每天”、“每小时”和“每10分钟”。谢谢!我想为我的Rails3.1应用程序运行调度程序。 最佳答案 这不是一个优雅的解决方案，但您可以安排它每天运行，并在实际开始工作之前检查日期是否为当月的第一天。 关于ruby-如何每月在Heroku运行一次Scheduler插件？，我们在StackOverflow上找到一个类似的问题： https://stackoverflow.com/questions/8692687/

  10. ruby-on-rails - 如何从 format.xml 中删除 <hash></hash> - 2

    我有一个对象has_many应呈现为xml的子对象。这不是问题。我的问题是我创建了一个Hash包含此数据，就像解析器需要它一样。但是rails自动将整个文件包含在.........我需要摆脱type="array"和我该如何处理？我没有在文档中找到任何内容。 最佳答案 我遇到了同样的问题；这是我的XML:我在用这个:entries.to_xml将散列数据转换为XML，但这会将条目的数据包装到中所以我修改了:entries.to_xml(root:"Contacts")但这仍然将转换后的XML包装在“联系人”中，将我的XML代码修改为

随机推荐