求助一个 Go 关闭 Pending 的 goroutine

[xxxxware]

最近在将 filebeat 源码嵌入项目

	go func(){
            if err := cmd.Filebeat(inputs.Init, cmd.FilebeatSettings()).Execute(); err != nil {
                os.Exit(1)
            }
        }

这个 cmd.Filebeat().Execute() 可以理解为 time.sleep(无限大)会一直 pending, 我怎么样才能关掉这个 goroutine 呢？ time.sleep(无限大)的情况也没有办法去 select context

谢谢大家！

[lev2048]

go 没发通过其他 goroutine kill 掉 goroutine, 加个 cmd 脚本调用，改成非阻塞吧

[jim9606]

按照 go 的 api 设计风格，阻塞调用是通过 deadline 防止无限阻塞的。通过 SetDeadline 设置后（注意是记录绝对时间，需要反复设置）阻塞调用即使未成功也要在 deadline 返回，好让 goroutine 有机会检查是否需要终止流程。
你找找你用的库有没有这种 api 吧？

[freshgoose]

不管是 go 的 goroutine 还是 python 的 Thread ，你都不可能有办法从代码本身关闭或杀死，只能在程序里自己 return ，你 return 了它才会释放。

[xmge]

做不到，因为某个 goroutine 无法关闭其他 goroutine 。

[useben]

我看不懂评论区了...

[tairan2006]

做不到，这种情况建议你用多进程……如果你改不了 Filebeat 的代码的话

[xxxxware]

@lev2048 @jim9606 @freshgoose @xmge 谢谢各位， 是的语言层面就没有 goroutine id 这种东西，最开始设计就设计成不能关闭。 现在碰到到情况是我的源码需要调用一个 go 写的软件，并二次开发其中的代码(需要在主程序中调用源码中的函数)，这个软件是 cmd 形式的(所以代码内部没有关闭的函数)。
感觉没路子走了 手动笑哭

[xxxxware]

cmd 脚本调用的话，就没办法通信， 和一次性交叉编译了

[xxxxware]

@jim9606 是的， 想避开多进程就是想通信和交叉编译更方便

[mengyx]

你可以将 Execute 修改为 ExecuteContext ，通过 Context 的 CancelFunc 来从外部终止此 goroutine

[labulaka521]

改下内部实现加个 ctx ？

[kwanzaa]

被调用方写的有问题，没有 ctx 或其他方式停止任务。

[buffzty]

加个信号 收工

[xxxxware]

@mengyx 和我的想法完全一致， 我调了 cancel 但是他还在运行， 哭了

[xxxxware]

@labulaka521 这个 cmd 库有 ctx ， 我调了没有反应。 不知道是不是使用问题

[xxxxware]

```
c := cmd.Filebeat(inputs.Init, cmd.FilebeatSettings())
ctx, cancel := context.WithCancel(context.Background)
go func(){
if err := c.ExecuteContextFunction(ctx); err != nil {
os.Exit(1)
}
}
time.sleep( 10 * time.Second )
cancel()
time.sleep( 10000 * time.Second )
```
cmd.Filebeat() 的返回类型中有 ctx ， 我改了一下源码由在里面新建变为传入一个 ctx ， 调用 cancel 后控制台还是在输出 filebeat 的日志

[lev2048]

你试试分两个程序？把阻塞这个操作包到一个 go 程序里，然后在主程序通过 cmd 包 执行，获取 pid ，停止 kill pid ？

[lev2048]

@lev2048 来把阻塞操作变成非阻塞

[mengyx]

仔细看了一下 filebeat ，里面会使用到 os.Exit 。 那还是建议拆成两个进程比较好

[xxxxware]

@mengyx @lev2048 谢谢 确实没有注意到 里面有调用 os.Exit 。已经通过 exec.commandContext 拆成两个进程，拿 cancel 去关闭了。 只能做进程通信啦