确保一次仅处理一个请求，并丢弃传入的其他请求

大家好，今天本人给大家带来文章《确保一次仅处理一个请求，并丢弃传入的其他请求》，文中内容主要涉及到，如果你对Golang方面的知识点感兴趣，那就请各位朋友继续看下去吧~希望能真正帮到你们，谢谢！

我有一个 goroutine，我们称之为 goprocessor，它处理来自其他 goroutine 的请求。

goprocessor 一次只能处理一个请求。如果当 goprocessor 仍在处理之前的 req1 请求时，出现一个请求（我们称之为 req2），则 req2 必须被丢弃并且将被丢弃。简直就输了。

我已经使用无缓冲通道和 select 语句实现了这样的逻辑，但我不确定是否有一种更简单更优雅的方法来完成我想要的。我的解决方案的一个简单示例是这样的

var c = make(chan string)

func main() {

    goRequest := func(request string, delay int) {
        time.Sleep(time.Duration(delay) * time.Second)
        fmt.Printf("Here I am request %v\n", request)
        select {
        case c <- request:
            fmt.Printf("%v sent\n", request)
        default:
            fmt.Printf("%v discarded\n", request)
        }
    }

    goProcessor := func() {
        for {
            msg := <-c
            fmt.Println("received", msg)
            time.Sleep(3 * time.Second)
            fmt.Println("processed", msg)
        }
    }

    go goRequest("First req", 1)
    go goRequest("Second req", 2)
    go goRequest("Third req", 5)
    go goProcessor()

    time.Sleep(10 * time.Second)

    fmt.Println("Main has finished")
}

解决方案

你所做的非常干净整洁。唯一可以简化的是在 goprocessor() 中使用 for range ，如下所示：

for msg := range c {
    // ...
}

但除此之外，这是惯用的。

这里可能会想到使用“trylock”。标准库中没有“trylock”（有 3rd party libs），但在您的情况下使用它并不更简单或更惯用，您必须检查 trylock() 是否返回 true，并且您必须解锁它。而且您仍然需要一个通道将结果发送到处理器，因此您的解决方案更简单、更清晰。

今天带大家了解了的相关知识，希望对你有所帮助；关于Golang的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~