复制代码
1
2
3
4
5
6
7
8
9
10
11
12
13RateLimiter rateLimiter = RateLimiter.create(1); // TPS 1 Executor executor = Executors.newFixedThreadPool(10); for (int i = 0; true; i++) { executor.execute(() -> { if(rateLimiter.tryAcquire()) { System.out.println(Thread.currentThread() + ", 执行"); } else { System.out.println(Thread.currentThread() + ", 跳过执行"); } }); Thread.sleep(300); }
最后
以上就是典雅发带最近收集整理的关于[Guava限流]RateLimiter使用的全部内容,更多相关[Guava限流]RateLimiter使用内容请搜索靠谱客的其他文章。
本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
发表评论 取消回复