在Go中如何实现一个共享队列？

珍惜时间，勤奋学习！今天给大家带来《在Go中如何实现一个共享队列？》，正文内容主要涉及到等等，如果你正在学习Golang，或者是对Golang有疑问，欢迎大家关注我！后面我会持续更新相关内容的，希望都能帮到正在学习的大家！

我正在尝试为负载均衡器实现最少连接算法。我正在使用优先级队列来按排序顺序保留每个服务器的连接数。 这是代码：

server = spq[0]
serverNumber = server.value

updatedPriority = server.priority + 1 // Increment connection count for server

spq.update(server, serverNumber, updatedPriority)

targetUrl, err := url.Parse(configuration.Servers[serverNumber])
if err != nil {
    log.Fatal(err)
}

// Send the request to the selected server
httputil.NewSingleHostReverseProxy(targetUrl).ServeHTTP(w, r)

updatedPriority = server.priority - 1 // Decrement connection count for server
spq.update(server, serverNumber, updatedPriority)

其中 spq 是我的优先级队列。

此代码将针对平衡器收到的每个请求运行。 但在记录每个请求的队列状态后，我没有得到正确的结果。 例如，在一种情况下，我看到队列包含两次具有不同优先级的同一服务器。

我确信这与跨请求同步和锁定队列有关。但我不确定在这种特殊情况下正确的方法是什么。

解决方案

如果这确实是您在多个 goroutine 中运行的代码，那么您显然存在竞争。

我不明白 spq.update。乍一看，它看起来像是一个对队列进行重新排序的函数，以使服务器在元素 0 处具有最少调用次数，但是为什么它同时需要 server 和 serverNumber 呢？ serverNumber 似乎是服务器的唯一 ID，既然您已经拥有服务器，为什么还需要它？

无论如何，你应该有一个由所有goroutine共享的sync.Mutex，并在第一行之前锁定互斥锁，并在spq.update之后解锁，并且你应该在代理调用之后再次锁定它，并在所有完成后解锁。仅当 server 是指针时，从 server.priority 中减去 1 的行才有效。如果它不是指针，您将丢失调用期间发生的所有服务器更新。

今天关于《在Go中如何实现一个共享队列？》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！