如何在 Windows 上进行非阻塞 IPC 读取？

Question

我有一个 Perl 脚本，它使用外部工具 (cleartool) 来收集有关文件列表的信息。我想使用 IPC 来避免为每个文件生成一个新进程：

use IPC::Open2;
my ($cin, $cout);
my $child = open2($cout, $cin, 'cleartool');

返回单行的命令效果很好。例如，

print $cin "describe -short $file\n";
my $description = <$cout>;

返回多行的命令让我陷入了如何使用整个响应而不被阻塞读取挂起的死胡同：

print $cin "lshistory $file\n";
# read and process $cout...

我尝试通过 fcntl 设置文件句柄以进行非阻塞读取：

use Fcntl;
my $flags = '';
fcntl($cout, F_GETFL, $flags);
$flags |= O_NONBLOCK;
fcntl($cout, F_SETFL, $flags);

但 Fcntl 终止并显示消息“您的供应商尚未定义 Fcntl 宏 F_GETFL。”

我尝试使用 IO::Handle 设置 $cout->blocking(0) 但失败（它返回 undef 并设置 $! 为“未知错误”）。

我尝试使用 select 来确定在尝试读取之前是否有可用数据：

my $rfd = '';
vec($rfd, fileno($cout), 1) = 1;
while (select($rfd, undef, undef, 0) >= 0) {
    my $n = read($cout, $buffer, 1024);
    print "Read $n bytes\n";
    # do something with $buffer...
}

但它挂起而没有读取任何内容。有谁知道如何使其工作（在 Windows 上）？

Answer 1

select 仅适用于 Windows 中的套接字。看起来 IPC::OpenX 使用普通文件句柄，因此您将无法将 select 与其创建的句柄一起使用。

如果您不需要 select 提供的超时/活动检测，您可以将句柄设置为非阻塞，只需按正常方式读取或写入。

如果您需要更细致的控制，IPC::Run 可能很适合您。

您还可以考虑创建一个socketpair 并将这些句柄用于您的子进程。较新的 perls（5.8 及更高版本）支持使用 TCP 套接字在 Windows 上进行 socketpair 模拟。

如果您尝试克隆 STDOUT 和 STDERR 来运行没有控制台的程序（即它是使用 wperl 而不是 perl 启动的），您将无法通过STDIO获取数据。

实际上，这对我的几个项目来说都是一个巨大的痛苦。我发现最有效的方法是编写子进程通过 TCP 连接到父服务器。如果您不控制子进程，请查看 IPC::Run 或 socketpair。

Answer 2

另一个混乱是使用具有较大或不太可能的缓冲区大小的sysread。

    print $cin "$command_for_cleartool\n";
    my ($description, $maxlen, $buffer) = ("", 65336);
    while (my $n = sysread $cout, $buffer, $maxlen) {
        $description .= $buffer;
        last if $n < $maxlen;
    }
    ... do something with $description ...

如果正好有 0 个字节的输入等待读取，sysread 将挂起。因此，如果cleartool 恰好生成 65336 字节的某个倍数，则上面的代码将挂起。如果您清楚地知道程序输出大小的上限，则可以使用上面的 $maxlen 的值。否则，你可以选择一个大且不太可能的数字并祈祷......

Answer 3

非阻塞 IO 在 Windows 上很难。在这种情况下，您可以将cleartool的输出发送到常规文件，并使用seek在每次从文件读取时重置文件上的eof标志：

my($cin, $cout);
my $somefile = "some/file";
open($cin, "| cleartool > $somefile");
open($cout, '<', $somefile);

...

print $cin "$command_for_cleartool\n";
# if necessary, wait until cleartool finishes with new output
seek $cout, 0, 1;     # clear eof condition from previous read
my @cleartool_output = <$cout>;  # capture recent output
... process output ...

尽管这可能不起作用如果cleartool缓冲它的输出就好了。