QPS不播放每秒不超过多个请求的流控制？

直接上代码：

设置qps 20， 按大家的理解，一秒钟，不能超过20个请求。 ` public class HelloSentinel {

private static void initFlowRules() { List rules = new ArrayList<>(); FlowRule rule = new FlowRule(); rule.setResource("HelloWorld"); rule.setGrade(RuleConstant.FLOW_GRADE_QPS); // Set limit QPS to 20. rule.setCount(20); rules.add(rule); FlowRuleManager.loadRules(rules); }

static { // 配置规则. initFlowRules(); }

public static String hello(String[] args) { Entry entry = null; try { entry = SphU.entry("HelloWorld"); // 资源中的逻辑. return "hello world"; } catch (BlockException e1) { return "blocked"; } finally { if (entry != null) { entry.exit(); } }

}

下面上测试程序

` public class HelloSentinelTest { @test public void testHello() { // 假设30个线程同时调用HelloSentinel的hello方法 int threadnum = 30; // 打印helloWorld次数 final AtomicInteger helloWorldCount = new AtomicInteger(0); // 打印blocked次数 final AtomicInteger blockedCount = new AtomicInteger(0); CountDownLatch latch = new CountDownLatch(threadnum); Runnable r = new Runnable() { public void run() { String result = HelloSentinel.hello(null); if ("hello world".equals(result)) { helloWorldCount.incrementAndGet(); } if ("blocked".equals(result)) { blockedCount.incrementAndGet(); } latch.countDown(); } };

for (int i = 0; i < threadnum; i++) {
	(new Thread(r)).start();
}
try {
	latch.await();
} catch (InterruptedException e) { 
	e.printStackTrace();
}
// 断言
Assert.isTrue(helloWorldCount.get() == 20, "helloWorldCount=" + helloWorldCount.get());
Assert.isTrue(blockedCount.get() == 10, "blockedCount=" + blockedCount.get());

}

测试并没有按期望的通过， 期望：helloWorld打印了20次。blocked 打印了10次。

经多次测试， helloWorld打印了30次，这不是与大家理解的（设置qps 20， 一秒钟，不能超过20个请求。 ）不一致吗？

原提问者GitHub用户hzdavid