登录
首页 >  Golang >  Go问答

调用 `golang.org/x/time` 中的 NewLimiter() 方法,以实现更高的突发限制,从而使 Allow() 方法能够真正应对更高的突发事件

来源:stackoverflow

时间:2024-03-19 12:03:36 119浏览 收藏

Go 语言中的 `golang.org/x/time` 包提供了 `NewLimiter()` 方法,可用于实现更高的突发限制。此方法可以确保 `Allow()` 方法能够真正应对更高的突发事件。通过设置适当的速率和突发大小,开发人员可以控制应用程序的令牌桶行为,从而限制每秒允许执行的操作数量。这种方法对于防止应用程序过载和确保平稳运行至关重要。

问题内容

您使用的 go 版本是什么(go 版本 )?

go version

输出:

go版本go1.12.17 darwin/amd64

您使用的是哪个版本的软件包(rate 版本)?

golang.org/x/time v0.0.0-20190308202827-9d24e82272b4

你做了什么?

在 amd64 上运行以下命令:

package main

import (
    "fmt"
    "golang.org/x/time/rate"
    "sync"
    "sync/atomic"
    "time"
)

func main() {
    now := time.now()
    t := time.after(time.second)

    limit := rate.limit(100)
    burst := 10
    l := rate.newlimiter(limit, burst)

    var count int
    for {
        select {
        case <-t:
            fmt.printf("%ds, %d\n", time.now().sub(now).nanoseconds()/1e9, count)
            return
        default:
            if l.allow() {
                count++
            }
        }
    }
}

您期望看到什么?

1s, 10

你看到了什么?

1s, 110

我对 count 不等于突发大小感到困惑。当我设置limit=100、burst=10时,应该允许()最大调用数为burst。


解决方案


突发不是最大速率。它是桶中的令牌数量以及填充率。

您将速率设置为每秒 100 个令牌,将突发容量设置为 10。

程序运行的一秒内可以消耗 100 个代币,加上突发容量所添加的 10 个代币,这并不奇怪。

如果您希望一秒钟内发生的事情不超过 10 件,请将速率设置为 10 并将突发设置为零。

好了,本文到此结束,带大家了解了《调用 `golang.org/x/time` 中的 NewLimiter() 方法,以实现更高的突发限制,从而使 Allow() 方法能够真正应对更高的突发事件》,希望本文对你有所帮助!关注golang学习网公众号,给大家分享更多Golang知识!

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