From 2e10e6db10c34e52e2455d55e57e5320355dc9da Mon Sep 17 00:00:00 2001 From: godotg Date: Tue, 18 Apr 2023 22:37:34 +0800 Subject: [PATCH] test[protocol]: benchmark test --- .../java/com/zfoo/protocol/SpeedTest.java | 49 ++++++++++--------- 1 file changed, 26 insertions(+), 23 deletions(-) diff --git a/protocol/src/test/java/com/zfoo/protocol/SpeedTest.java b/protocol/src/test/java/com/zfoo/protocol/SpeedTest.java index a3f278cd..77b3503b 100644 --- a/protocol/src/test/java/com/zfoo/protocol/SpeedTest.java +++ b/protocol/src/test/java/com/zfoo/protocol/SpeedTest.java @@ -56,19 +56,20 @@ public class SpeedTest { @Ignore @Test public void singleThreadBenchmarks() { - if (benchmark <= 0 || benchmark >= 10_0000_0000) { - return; + while (true) { + if (benchmark > 160_0000) { + return; + } + System.out.println(StringUtils.MULTIPLE_HYPHENS); + System.out.println(StringUtils.format("[单线程性能测试-->[benchmark:{}]]", benchmark)); + + zfooTest(); + protobufTest(); + kryoTest(); + + // 递归执行,多跑几遍 + benchmark = benchmark * 2; } - System.out.println(StringUtils.MULTIPLE_HYPHENS); - System.out.println(StringUtils.format("[单线程性能测试-->[benchmark:{}]]", benchmark)); - - zfooTest(); - protobufTest(); - kryoTest(); - - // 递归执行,多跑几遍 - benchmark = benchmark * 2; - singleThreadBenchmarks(); } /** @@ -77,18 +78,20 @@ public class SpeedTest { @Ignore @Test public void multipleThreadBenchmarks() throws InterruptedException { - if (benchmark <= 0 || benchmark >= 10_0000_0000) { - return; + while (true) { + if (benchmark > 160_0000) { + return; + } + System.out.println(StringUtils.MULTIPLE_HYPHENS); + System.out.println(StringUtils.format("[多线程性能测试-->[benchmark:{}]]", benchmark)); + + zfooMultipleThreadTest(); + protobufMultipleThreadTest(); + kryoMultipleThreadTest(); + + benchmark = benchmark * 2; + multipleThreadBenchmarks(); } - System.out.println(StringUtils.MULTIPLE_HYPHENS); - System.out.println(StringUtils.format("[多线程性能测试-->[benchmark:{}]]", benchmark)); - - zfooMultipleThreadTest(); - protobufMultipleThreadTest(); - kryoMultipleThreadTest(); - - benchmark = benchmark * 2; - multipleThreadBenchmarks(); } @Ignore