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