有人遇到过 Golang select case 语句和 default 语句都没执行的情况吗？

[Morriaty]

程序大致逻辑如下，会正常运行一段时间，receiving msg和sleeping会交替打印，但运行一段时间后最后输出一段pipeline sleeping之后就再也没有日志了，没有pipeline terminate，没有 panic，也没有到 defer 那一步

var sigChan = make(chan os.Signal, 1)

func init() {
	signal.Notify(
		sigChan,
		os.Kill,
		os.Interrupt,
		syscall.SIGHUP,
		syscall.SIGINT,
		syscall.SIGTERM,
		syscall.SIGQUIT,
	)
}

func (ip *InnerPipeline) Run() {

	defer func() {
		log.Infof("pipeline<%s> defer exit", ip.name)
	}()

	for {

		select {
		case im := <-ip.messageQueue:
			log.Debugf("receiving msg %+v", im)

			// some logic ....
                        xxxxxxxxxxxxxxx

			log.Debugf("quit case")

		case <-sigChan:
			log.Infof("pipeline terminate")
			return

		default:
			log.Debugf("current chan len: %d", len(ip.messageQueue))
			
			// some logic ....
                        xxxxxxxxxxxxxxx            

			log.Debugf("pipeline<%s> sleeping...", ip.name)
			time.Sleep(50 * time.Millisecond)
		}
	}
}

[index90]

大概率你的 main 函数还没等 Run 函数 return 就结束了

[paulter]

提问之前，起码先抽出一个最小可运行的 demo 程序，以便重现问题。

[Morriaty]

@index90 忘了描述了，主程序没有结束，msg produce 的地方依然在打印日志

[Hstar]

建议排查 default 块里的代码, 精简到只有 log 和 Sleep 试试是否在循环

[gamexg]

golang pprof 直接看卡在哪一步了

[fds]

for 开始时打印下 ip.messageQueue

[nuk]

gdb 一把就知道了啊。。

[Morriaty]

@Hstar @fds 好的我试试
@gamexg 我加下看看，但感觉不一定看得懂🤣
@nuk 开发环境无法复现，生产环境要跑一两个小时才会出现这个问题，这种情况下怎么打断点啊？

[nuk]

@Morriaty 隔一会检查一下 log，要是太久没出现 log 就 dump stack 出来。。不过你这个问题我觉得像是 signal channel 过早关闭。。于是就在里面死循环了。。

[cyrivlclth]

可能是 some logic 里面的逻辑耗时太长卡住了吧。

[Morriaty]

@nuk 额，代码里是没有主动关闭 chan 的地方，而且就算关闭了，也会打出 pipeline terminate 日志吧

[Morriaty]

@cyrivlclth 如果是 some logic 堵住了，就不会打印 sleeping 的日志啊，实际日志是停在 sleeping 这里的

[nacosboy]

@Morriaty 我觉得也是 some logic 在特定场景下 block 住了，打印出的 sleeping 日志，可能是上一次循环打印出的。