dongzhun1857 2015-09-20 23:42
浏览 23
已采纳

当非阻塞读取行挂起时,goroutine泄漏

Assuming you have a structure like this:

ch := make(chan string)
errCh := make(chan error)
go func() {
    line, _, err := bufio.NewReader(r).ReadLine()
    if err != nil {
        errCh <- err
    } else {
        ch <- string(line)
    }
}()
select {
case err := <-errCh:
    return "", err
case line := <-ch:
    return line, nil
case <-time.After(5 * time.Second):
    return "", TimeoutError
}

In the case of the 5 second timeout, the goroutine hangs until ReadLine returns, which may never happen. My project is a long-running server, so I don't want a buildup of stuck goroutines.

  • 写回答

1条回答 默认 最新

  • duanmu5641 2015-09-21 01:33
    关注

    ReadLine will not return until either the process exits or the method reads a line. There's no deadline or timeout mechanism for pipes.

    The goroutine will block if the call to ReadLine returns after the timeout. This can be fixed by using buffered channels:

    ch := make(chan string, 1)
    errCh := make(chan error, 1)
    

    The application should call Wait to cleanup resources associated with the command. The goroutine is a good place to call it:

    go func() {
      line, _, err := bufio.NewReader(r).ReadLine()
      if err != nil {
        errCh <- err
      } else {
        ch <- string(line)
      }
      cmd.Wait() // <-- add this line
    }()
    

    This will cause the goroutine to block, the very thing you are trying to avoid. The alternative is that the application leaks resources for each command.

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

悬赏问题

  • ¥50 adb连接不到手机是怎么回事?
  • ¥15 vs2022无法联网
  • ¥15 TCP的客户端和服务器的互联
  • ¥15 VB.NET操作免驱摄像头
  • ¥15 笔记本上移动热点开关状态查询
  • ¥85 类鸟群Boids——仿真鸟群避障的相关问题
  • ¥15 CFEDEM自带算例错误,如何解决?
  • ¥15 有没有会使用flac3d软件的家人
  • ¥20 360摄像头无法解绑使用,请教解绑当前账号绑定问题,
  • ¥15 docker实践项目