Блог

Я использовал PProf для анализа трассировки для конвейера данных с производителем и потребителем. Я не уверен, как мне следует это читать, но из профиля задержки планировщика, chanrecv chansend на который приходится приличная часть моего общего времени выполнения.

Мне трудно в это поверить, так что это говорит о том, что отправка/прием по каналу go занимает так много времени, или это относится только к отставанию производителя, что приводит к chanrecv блокировке. И потенциально, как я могу сделать это более эффективным?

Пример кода:

 func consume(in chan User) {
    out := make(chan UserDetail)
    go func() {
        for user := range in {
            if userDetail, err := getUserDetails(user); err == nil {
                out <- userDetail
            }
        }
        close(out)
    }()
    return out
}

func produce() {
    out := make(chan User)
    go func() {
        // could be issuing a paginated api call to get users list
        for user := range users {
            out <- user
        }
        close(out)
    }()
    return out
}


func main() {
    userChan := produce() // get all users
    userDetailChannels := []chan User

    // fanout to 8 workers
    for workerIndex := 0; workerIndex < 8; workerIndex   {
        userDetailChannels = append(userDetailChannels, consume(userChan))
    }
}