Perl在Windows环境下实现STDIN非阻塞无缓冲的方案咨询

问题原因说明 #

Windows 平台的 Perl 中，blocking() 方法仅对套接字句柄有效，控制台输入、匿名管道等常规标准输入场景不支持直接设置非阻塞模式，调用STDIN->blocking(0)时底层会尝试调用套接字相关API，因此会返回「An operation was attempted on something that is not a socket」报错。
你提到的旧博文测试场景大概率是将套接字重定向为标准输入，和你现在的终端交互、管道通信场景不符，并非发布后相关机制发生了变更。

可行方案 #

方案1：独立输入线程+队列（兼容性最高，推荐国际象棋引擎使用） #

该方案无需依赖第三方Win32模块，Strawberry Perl 自带threads和Thread::Queue模块，同时兼容终端交互和管道通信场景，也是多数 UCI 国际象棋引擎的通用处理方案：开独立线程同步读取标准输入，将读取到的内容写入全局队列，主线程可无阻塞从队列拉取输入。
示例代码：

use strict;
use warnings;
use threads;
use Thread::Queue;

# 全局输入队列
my $input_queue = Thread::Queue->new();

# 启动输入读取线程
my $input_thread = threads->create(sub {
    binmode STDIN;
    while (my $line = <STDIN>) {
        $input_queue->enqueue($line);
    }
    # 输入流关闭时插入终止标记
    $input_queue->enqueue(undef);
});

binmode STDOUT;
STDOUT->autoflush(1);

# 主循环
while (1) {
    # 非阻塞拉取队列内容
    while (defined(my $input = $input_queue->dequeue_nb())) {
        # 处理输入，比如引擎的 UCI 命令解析
        chomp $input;
        if ($input eq 'quit') {
            $input_thread->join();
            exit 0;
        }
        # 其他命令处理逻辑
        print "received command: $input\n";
    }

    # 这里写引擎的其他逻辑，比如思考、迭代搜索等
    sleep 0.01;
}

方案2：Win32 API 原生实现非阻塞检查 #

如果不想使用多线程，可以调用Windows原生APIPeekNamedPipe提前检查管道/标准输入是否有可读数据，无需触发阻塞读取，需要依赖Win32::API模块（Strawberry Perl 自带）：
示例代码：

use strict;
use warnings;
use Win32::API;

# 导入PeekNamedPipe API
Win32::API->Import(
    'kernel32',
    'BOOL PeekNamedPipe(
        HANDLE hNamedPipe,
        LPVOID lpBuffer,
        DWORD nBufferSize,
        LPDWORD lpBytesRead,
        LPDWORD lpTotalBytesAvail,
        LPDWORD lpBytesLeftThisMessage
    )'
) or die "Failed to import PeekNamedPipe: $^E";

binmode STDIN;
binmode STDOUT;
STDOUT->autoflush(1);

# 获取标准输入的Win32句柄
my $stdin_handle = Win32::GetStdHandle(Win32::STD_INPUT_HANDLE());

while (1) {
    my $bytes_avail = 0;
    # 检查是否有可读数据
    if (PeekNamedPipe($stdin_handle, 0, 0, 0, \$bytes_avail, 0)) {
        if ($bytes_avail > 0) {
            my $buffer;
            my $read_count = sysread(STDIN, $buffer, $bytes_avail);
            if (!defined $read_count || $read_count == 0) {
                exit 0;
            }
            # 处理读取到的内容
            print "received: $buffer\n";
        }
    }

    # 引擎其他逻辑
    sleep 0.01;
}

跨平台兼容建议 #

可以在代码中加入平台判断，Unix类系统沿用原来的IO::Select或非阻塞sysread方案，Windows系统使用上述两种方案之一即可。

内容的提问来源于stack exchange，提问作者Guido Flohr