需求:
fun main(){ x1(id string) (objectEntity entity, error) {} x2(id string) (objectEntity []entity, error) {} x3(id string) (objectEntity entity, error) {} } x1(),x2(),x3()分别是三个互相不关联的 3 个 sql 查询. x1 会返回一个 objectEntity, error, x2 会返回一个[]objectEntity, x3 会返回一个 objectEntity. 我会拿到这 3 个返回值,然后进行拼接.
本来直接使用 goroutine 和 channel 来进行请求. 但是我遇到一个问题, 不管是 x1,x2,x3 进行查询,返回值 都有 error. 大家有什么好的办法吗?
再另外说一句,既然要同步拼接,根本不需要走协程,同步执行就行了.异步反而更麻烦
“`
我加了伪代码… 求大家帮忙写个 gorouter
“`
func main() {
id := 1
user1, err := x1(id)
if err != nil {
// 处理
}
userList, err := x2(id)
if err != nil {
// 处理
}
user2, err := x3(id)
if err != nil {
// 处理
}
// 然后 user1, userList, user2 进行拼接
}
type User struct {
Id int `json:”id”`
Name string `json:”name”`
}
func x1(id int) (User, error) {
var err error
user := User{
Id: 1,
Name: “xx”,
}
return user, err
}
func x2(id int) ([]User, error) {
var err error
user := User{
Id: 1,
Name: “xx”,
}
userList := []User{user, user}
return userList, err
}
func x3(id int) (User, error) {
var err error
var user User
{
}
err = errors.New(“假设出现错误”)
return user, err
}
“`
“`
异步这个你说的是对的,如果所有查询都正常的话.
粗略想了下你要用 channel 需要就需要把结果和 error 统一包一个结构体.可能用 sync.WaitGroup 更简单一些.
// 然后 user1, userList, user2 进行拼接
}
type User struct {
Id int `json:”id”`
Name string `json:”name”`
}
func x1(id int) (User, error) {
var err error
user := User{
Id: 1,
Name: “xx”,
}
return user, err
}
func x2(id int) ([]User, error) {
var err error
user := User{
Id: 1,
Name: “xx”,
}
userList := []User{user, user}
return userList, err
}
func x3(id int) (User, error) {
var err error
var user User
{
}
err = errors.New(“假设出现错误”)
return user, err
}
“`
wg.Add(3)
errCh := make(chan error)
userCh := make(chan *User)
go func(){
defer wg.Done()
user, err := x1()
if err != nil {
}
}()