问题描述:
有两个服务:我们分别称他们为:serverClient、serverSvr
serverSvr端作为GRPC服务端
serverClient端作为GRPC客户端
serverClient发现serverSvr后,正常发送数据,发送一段时间后,发现grpc 报错如下:
code = Unavailable desc = transport is closing。
通过排查,发现所有端口都是正常的,包括GPRC端口,MQ端口,Redis端口,保活也正常。
问题处理:
发现是serverSvr死锁导致。

死锁原因:先看如下两个代码片
片段1

	limiter := make(chan int, DataDefine.Limit)
	for task := range req {
		limiter <- 1
		go t.goDeleteTask(task, limiter)
	}

片段2:

func (t *TaskManager) goDeleteTask(reqs Proto.RecordDeleteReq, limiter chan int) {
	if !condition{
	dosomething
	return
	}else{
	doanysomething
	}
	<-limiter
}

从这两个代码片看出问题了吗,一旦condition触发,然后函数return,limiter通道未消费,然后程序就会进入死锁。
那么怎么处理呢?
修改代码片段2:

func (t *TaskManager) goDeleteTask(reqs Proto.RecordDeleteReq, limiter chan int) {
	if !condition{
	dosomething
	<-limiter
	return
	}else{
	doanysomething
	}
	<-limiter
}

注:go程序死锁,不一定是因为锁,也可能是通道阻塞造成的

Logo

北京人形旗下天工造物具身智能开源社区,聚焦具身天工与慧思开物两大平台

更多推荐