固定QPS异步任务功能再探

文章摘要

本文介绍了一种使用Java实现固定QPS异步任务的方法。作者之前分享了一种利用缓存线程池和Semaphore的实现方式，而本文展示了第二种实现思路，即通过队列和守护线程的方式来降低线程数量，并提供了详细的实现代码。

入口方法

入口方法被添加到com.funtester.frame.SourceCode工具类中，关键字为“funer”。这个方法默认使用16个QPS，并提供了调整QPS的方式。入口方法将任务添加到异步执行队列中。

实现细节

实现细节包括使用了java.util.concurrent.LinkedBlockingQueue来存储待执行的异步任务，并提供了一个非阻塞的添加任务方法。同时，作者实现了一个守护线程来从队列中取出任务并执行，以及在主线程结束后继续处理剩余任务的逻辑。

自测

通过一个简单的用例，作者展示了如何使用setMaxQps方法设置QPS，并通过调用funer方法来执行异步任务。控制台输出显示了任务被正确地以固定的QPS执行，以及在所有任务执行完成后，异步线程池的关闭。

原创专题推荐

文章最后推荐了FunTester的一系列原创专题，包括接口功能测试、性能测试、Groovy语言、Java、Go、Python等编程语言，以及单元测试、测试理论、UI自动化和测试工具等相关内容。

FunTester

查看原文：固定QPS异步任务功能再探

文章来源：

FunTester

扫码关注公众号