Google RateLimiter不适用于计数器

作者: 绵绵
发布时间: 2024-01-19 05:19:47 (6月前)
转自：

3 条回复

0#
回复此人
部落用户 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> 除了@ DodgyCodeException有关输出刷新和连接的建议 <code> +1 </code> ，让我们运行此代码以确保您了解如何 <code> RateLimiter </code> 作品： <pre> <code> final double permitsPerSecond = 1; RateLimiter limiter = RateLimiter.create(permitsPerSecond); final Stopwatch stopwatch = Stopwatch.createStarted(); int i = 0; for (; i < 2 * permitsPerSecond; i++) { limiter.acquire(); } System.out.println("Elapsed = " + stopwatch.stop().elapsed(TimeUnit.MILLISECONDS) + "ms"); System.out.println("Number of records processed = " + i); </code> </pre> （请注意，我将尝试次数设置为两次 <code> permitsPerSecond </code> 数字。）当你设置 <code> permitsPerSecond </code> 至 <code> 1 </code> ，你会看到的： <BLOCKQUOTE> 经过= 1001ms 处理的记录数= 2 </BLOCKQUOTE> 对于 <code> permitsPerSecond = 10; </code> 和 <code> permitsPerSecond = 100; </code> 它接近（在数学意义上）2s限制，因为第11或第101次尝试等待设置的限制 <code> RateLimiter </code> ： <BLOCKQUOTE> 经过= 1902ms 处理的记录数= 20 </BLOCKQUOTE> 和 <BLOCKQUOTE> 经历= 1991ms 处理的记录数= 200 </BLOCKQUOTE> </DIV>

编辑
1#
回复此人
v-star*위위 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> RateLimiter工作正常。问题是您的输出是缓冲的，因为您每次都不会刷新它。通常，标准输出是行缓冲的。所以，如果你写了 <pre> <code> System.out.println("Number of records processed = " + (i+1)); </code> </pre> 你会看到100暂停。但是，你有什么： System.out.print（“\ r \ n已处理的记录数=”+ i + 1）; 有两个问题。首先，“\ r”不作为新行，不会引起冲洗;因此整个输出都被缓冲并一次性打印到控制台。其次，你需要把（i + 1）括在括号中。你将i追加到字符串，然后将1附加到结果字符串。 </DIV>

编辑

登录后才能参与评论