登录
首页 >  Golang >  Go问答

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

来源:stackoverflow

时间:2024-03-15 14:54:26 189浏览 收藏

珍惜时间,勤奋学习!今天给大家带来《在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学习网公众号下多多回复交流;文中若有不正之处,也希望回复留言以告知!

声明:本文转载于:stackoverflow 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>