Julia中bytesavailable(stdin)始终返回0的非阻塞读取问题求助

问题原因 #

当你通过redirect_stdin()重定向标准输入到管道后，stdin被包装为RedirectedStream，而管道的缓冲区数据存储在内核空间中。bytesavailable()函数只能检测用户空间缓冲区中的数据，无法感知内核中待读取的内容，因此即使有数据可读，也会返回0。而eof()返回false是可靠的，因为它检测的是流的状态而非缓冲区数据量。

解决方法 #

方法1：异步任务+通道（推荐，符合Julia并发模型） #

启动异步任务持续读取stdin，将结果发送到通道，主线程可非阻塞检查通道是否有数据：

# 创建通道用于传递读取结果
input_channel = Channel{String}(Inf)

# 异步任务读取stdin
@async begin
    while !eof(stdin)
        line = readline(stdin)
        put!(input_channel, line)
    end
    close(input_channel)
end

# 主线程非阻塞处理数据
while isopen(input_channel)
    if isready(input_channel)
        received_line = take!(input_channel)
        println("读取到行: ", received_line)
    else
        # 执行其他非阻塞任务
        sleep(0.1)
    end
end

方法2：低级文件描述符轮询 #

使用Base.poll_fd检测文件描述符是否可读，实现非阻塞检查：

(rd, wr) = redirect_stdin()
write(wr, "test 1\n")
flush(wr)

# 获取stdin的文件描述符
stdin_fd = Base.fd(stdin)

# 非阻塞检查是否可读（超时0秒）
poll_status = Base.poll_fd(stdin_fd, Base.POLLIN, 0)
if (poll_status & Base.POLLIN) != 0
    println("检测到可读数据")
    line = readline(stdin)
    println(line)
end

close(rd)
close(wr)

方法3：直接操作管道（测试场景） #

如果仅用于测试非阻塞读取，可直接对管道对象使用poll_fd，绕开stdin的包装层：

(rd, wr) = Pipe()
write(wr, "test 1\n")
flush(wr)

pipe_fd = Base.fd(rd)
poll_status = Base.poll_fd(pipe_fd, Base.POLLIN, 0)
if (poll_status & Base.POLLIN) != 0
    println("管道有可读数据")
    line = readline(rd)
    println(line)
end

close(rd)
close(wr)

注意事项 #

• bytesavailable()不适合用于管道、套接字等内核缓冲的流，它仅对内存中的流（如IOBuffer）能准确返回可用字节数。
• Julia的异步任务是轻量级的，推荐用方法1实现非阻塞IO，避免手动轮询的复杂度。

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