package pkg import ( "ai_scheduler/internal/entitys" "encoding/json" ) func JsonStringIgonErr(data interface{}) string { dataByte, _ := json.Marshal(data) return string(dataByte) } // IsChannelClosed 检查给定的 channel 是否已经关闭 // 参数 ch: 要检查的 channel,类型为 chan entitys.ResponseData // 返回值: bool 类型,true 表示 channel 已关闭,false 表示未关闭 func IsChannelClosed(ch chan entitys.ResponseData) bool { select { case _, ok := <-ch: // 尝试从 channel 中读取数据 return !ok // 如果 ok=false,说明 channel 已关闭 default: // 如果 channel 暂时无数据可读(但不一定关闭) return false // channel 未关闭(但可能有数据未读取) } }