主页 / unix / 问题 / 559235
Accepted
Ole Tange
Asked: 2019-12-28 22:16:22 +0800 CST

读取 STDIN 超时

  • 772

我想阅读 STDIN，但最多 5 秒。之后，我想处理我到目前为止读过的数据。

select似乎正是为此而设计的：等到有输入或超时。

如果有输入，我应该只读取那个非阻塞的。

所以我认为这会起作用：

#!/usr/bin/perl -w

use strict;
use Fcntl;

open(my $in, "<&", "STDIN") or die;
my $buf = "";
my $readsize = 10;

# Make $in non-blocking
fcntl($in, &F_SETFL, fcntl($in, &F_GETFL, 0) | &O_NONBLOCK);
while(not eof($in)) {
    my $starttime = time();
    my $rin = my $win = my $ein = '';
    vec($rin, fileno($in),  1) = 1;
    while(time() < $starttime + 5 and length $buf < $readsize) {
        # Wait up to 5 seconds for input                                                               
        select($rin, $win, $ein, $starttime + 5 - time());
        # Read everything that is available in the inputbuffer                                         
        while(read($in,$buf,$readsize,length $buf)) {}
    }
    print "B:",$buf;
    $buf = "";
}

当运行时：

(echo block1;sleep 1; echo block1; sleep 6;echo block2)|
  perl nonblockstdin.pl

块合并在一起。它们应该是两个块，因为块 2 会在 6 秒后开始。

我究竟做错了什么？

perl

2 个回答

  1. Best Answer

    一些问题：

    • 设置O_NONBLOCK会影响打开的文件描述，而不仅仅是文件描述符。例如，如果你运行that-script; cat，你会看到cat: -: Resource temporarily unavailable，因为cat's stdin 变成了非阻塞的
    • 如果您使用非阻塞 I/O，read()如果此时没有输入并且设置了 eof，则系统调用会返回 EAGAIN 错误。perl的eof()调用read()并暗示进行缓冲 I/O。您不能真正将其用于非阻塞 I/O。在您的示例中，第一个block1被读取eof()，然后select()等待sleep 1，第二个block1被读取read()，返回两个block1s。

    在这里，您最好使用阻塞 I/O 并使用alarm()例如超时。如果使用非阻塞 I/O 和select()，请不要使用eof()和使用sysread()，如果事先设置，read()请确保在退出时清除标志（在标准输入上设置仍然是一个坏主意，因为标准输入可以与其他进程共享）。O_NONBLOCKO_NONBLOCK

    • 1

  2. 按照 Stephane 的建议，我想出了这个，到目前为止似乎有效。

    #!/usr/bin/perl -w                                                                                                                                   

use strict;

my $timeout = 2;
my $buf = "";
my $blocksize = 30;
my $readsize;
my $nread;
my $buflen;
my $alarm;
my $eof;

open(my $in, "<&", "STDIN") or die;

do {
    eval {
        local $SIG{ALRM} = sub { die "alarm\n" }; # NB: \n required                                                                                  
        alarm $timeout;
        # Add upto the next full block                                                                                                               
        $readsize = $blocksize - (length $buf) % $blocksize;
        do {
            $nread = sysread $in, $buf, $readsize, length $buf;
            $readsize -= $nread;
        } while($nread and $readsize);
        alarm 0;
    };
    if ($@) {
        die unless $@ eq "alarm\n";   # propagate unexpected errors                                                                                  
        $alarm = 1;
    } else {
        $alarm = 0;
    }
    print "B:$buf<\n";
    $buf = "";
    $eof = not ($nread or $alarm);
} while(not $eof);
    • 0

相关问题