go - Golang多个goroutine通过引用共享相同的变量

我正在尝试运行多个goroutine，以修改通过引用传递的同一变量。

但是我确信我实现此功能的方式在功能上是错误的。即使它在我的测试中似乎可以正常工作，但我仍然感觉到，如果第二个goroutine的运行时间比第一个goroutine的运行时间长得多，则该模式将在第一个goroutine完成时终止父函数。

我希望您的意见/建议/建议。

package auth

import (
    "regexp"

    zxcvbn "github.com/nbutton23/zxcvbn-go"
    "golang.org/x/net/context"
)

type AuthService struct{}

func NewAuthService() *AuthService {
    return &AuthService{}
}

func (this *AuthService) ValidateCredentials(ctx context.Context, req *ValidateCredentialsRequest) (*ValidateCredentialsResponse, error) {
    c := make(chan *ValidateCredentialsResponse)

    go validatePassword(req.GetPassword(), c)
    go validateUsername(req.GetUsername(), c)

    c <- &ValidateCredentialsResponse{IsValid: true}

    return <-c, nil
}

func validateUsername(email string, c chan *ValidateCredentialsResponse) {
    for {
        res := <-c

        if email == "" {
            res.IsValid = false
            res.Username = "Please provide your email address."
        } else if len(email) > 128 {
            res.IsValid = false
            res.Username = "Email address can not exceed 128 characters."
        } else if !regexp.MustCompile(`.+@.+`).MatchString(email) {
            res.IsValid = false
            res.Username = "Please enter a valid email address."
        }

        c <- res
    }
}

func validatePassword(password string, c chan *ValidateCredentialsResponse) {
    for {
        res := <-c

        if password == "" {
            res.IsValid = false
            res.Password = "Please provide your password."
        } else {
            quality := zxcvbn.PasswordStrength(password, []string{})
            if quality.Score < 3 {
                res.IsValid = false
                res.Password = "Your password is weak."
            }
        }

        c <- res
    }
}

最佳答案

您确定需要goroutines来执行简单的验证吗？
无论如何，您编写的代码都使用goroutine，但是它们不是并行运行的。

您的代码中发生了什么:
您创建非缓冲通道并将CredentialResponse变量放入其中。
然后，一个goroutine(两个)中的任何一个从通道读取变量，执行一些操作，然后将变量放回通道。
当第一个goroutine正在执行某些操作时，第二个仅在等待通道中的值。

因此，您的代码使用goroutines，但几乎不能将其称为并行。

如果您需要执行一些繁重的操作来验证数据(例如io ops或CPU)，则可能需要使用goroutines，但是如果使用CPU，则需要指定GOMAXPROCS> 1以获得一定的性能。

如果我想使用goroutines进行验证，我会像这样写:

func validateCredentials(req *ValidateCredentialsRequest){
    ch := make(chan bool, 2)
    go func(name string){
    // ... validation code
        ch <- true // or false

    }(req.GetUsername())

    go func(pwd string){
    // ... validation code
        ch <- true // or false
    }(req.GetPassword())

    valid := true
    for i := 0; i < 2; i++ {
        v := <- result
        valid = valid && v
    }

    // ...
}