最近在将 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
谢谢大家！
 |
1
lev2048 Mar 22, 2022
go 没发通过其他 goroutine kill 掉 goroutine, 加个 cmd 脚本调用，改成非阻塞吧
|
 |
2
jim9606 Mar 22, 2022
按照 go 的 api 设计风格，阻塞调用是通过 deadline 防止无限阻塞的。通过 SetDeadline 设置后（注意是记录绝对时间，需要反复设置）阻塞调用即使未成功也要在 deadline 返回，好让 goroutine 有机会检查是否需要终止流程。
你找找你用的库有没有这种 api 吧？ |
 |
3
freshgoose Mar 22, 2022
不管是 go 的 goroutine 还是 python 的 Thread ，你都不可能有办法从代码本身关闭或杀死，只能在程序里自己 return ，你 return 了它才会释放。
|
 |
4
xmge Mar 22, 2022
做不到，因为某个 goroutine 无法关闭其他 goroutine 。
|
 |
5
useben Mar 22, 2022
我看不懂评论区了...
|
 |
6
tairan2006 Mar 22, 2022
做不到，这种情况建议你用多进程……如果你改不了 Filebeat 的代码的话
|
 |
7
xxxxware OP @lev2048 @jim9606 @freshgoose @xmge 谢谢各位， 是的语言层面就没有 goroutine id 这种东西，最开始设计就设计成不能关闭。 现在碰到到情况是我的源码需要调用一个 go 写的软件，并二次开发其中的代码(需要在主程序中调用源码中的函数)，这个软件是 cmd 形式的(所以代码内部没有关闭的函数)。
感觉没路子走了 手动笑哭 |
|
8
xxxxware OP cmd 脚本调用的话，就没办法通信， 和一次性交叉编译了
|
 |
10
mengyx Mar 22, 2022
你可以将 Execute 修改为 ExecuteContext ，通过 Context 的 CancelFunc 来从外部终止此 goroutine
|
 |
11
labulaka521 Mar 22, 2022 via iPhone
改下内部实现加个 ctx ？
|
 |
12
kwanzaa Mar 22, 2022
被调用方写的有问题，没有 ctx 或其他方式停止任务。
|
 |
13
buffzty Mar 22, 2022
加个信号 收工
|
|
15
xxxxware OP @labulaka521 这个 cmd 库有 ctx ， 我调了没有反应。 不知道是不是使用问题
|
|
16
xxxxware OP ```
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 的日志 |
|
17
lev2048 Mar 23, 2022
你试试分两个程序？把阻塞这个操作包到一个 go 程序里，然后在主程序通过 cmd 包 执行，获取 pid ，停止 kill pid ？
|
|
19
mengyx Mar 23, 2022
仔细看了一下 filebeat ，里面会使用到 os.Exit 。 那还是建议拆成两个进程比较好
|
Select Language