From 280c4d634c84366b2c7f3bbc83dd609bcc62ff4a Mon Sep 17 00:00:00 2001
From: sun <jaysunxiao@gmail.com>
Date: Fri, 22 Sep 2023 14:47:17 +0800
Subject: [PATCH] del[protocol]: remove fury test, record not support

---
 protocol/pom.xml                              | 13 ----
 .../com/zfoo/protocol/BenchmarkTesting.java   | 64 -------------------
 2 files changed, 77 deletions(-)

diff --git a/protocol/pom.xml b/protocol/pom.xml
index 0ca3fb38..05d950ef 100644
--- a/protocol/pom.xml
+++ b/protocol/pom.xml
@@ -128,19 +128,6 @@
             <scope>test</scope>
         </dependency>
 
-<!--        <dependency>-->
-<!--            <groupId>org.furyio</groupId>-->
-<!--            <artifactId>fury-core</artifactId>-->
-<!--            <version>0.1.0</version>-->
-<!--            <scope>test</scope>-->
-<!--            <exclusions>-->
-<!--                <exclusion>-->
-<!--                    <artifactId>slf4j-api</artifactId>-->
-<!--                    <groupId>org.slf4j</groupId>-->
-<!--                </exclusion>-->
-<!--            </exclusions>-->
-<!--        </dependency>-->
-
         <dependency>
             <groupId>junit</groupId>
             <artifactId>junit</artifactId>
diff --git a/protocol/src/test/java/com/zfoo/protocol/BenchmarkTesting.java b/protocol/src/test/java/com/zfoo/protocol/BenchmarkTesting.java
index 0eeaa62e..ee7581f4 100644
--- a/protocol/src/test/java/com/zfoo/protocol/BenchmarkTesting.java
+++ b/protocol/src/test/java/com/zfoo/protocol/BenchmarkTesting.java
@@ -63,7 +63,6 @@ public class BenchmarkTesting {
             System.out.println(StringUtils.format("[单线程性能测试-->[benchmark:{}]]", benchmark));
 
             zfooTest();
-//            furyTest();
             protobufTest();
             kryoTest();
 
@@ -85,7 +84,6 @@ public class BenchmarkTesting {
             System.out.println(StringUtils.format("[多线程性能测试-->[benchmark:{}]]", benchmark));
 
             zfooMultipleThreadTest();
-//            furyMultipleThreadTest();
             protobufMultipleThreadTest();
             kryoMultipleThreadTest();
 
@@ -137,42 +135,6 @@ public class BenchmarkTesting {
         System.out.println(StringUtils.format("[zfoo]     [复杂对象] [thread:{}] [size:{}] [time:{}]", Thread.currentThread().getName(), buffer.writerIndex(), System.currentTimeMillis() - startTime));
     }
 
-//    @Test
-//    public void furyTest() {
-//        var buffer = MemoryBuffer.newHeapBuffer(1_0000);
-//        // 序列化和反序列化简单对象
-//        long startTime = System.currentTimeMillis();
-//        for (int i = 0; i < benchmark; i++) {
-//            buffer.writerIndex(0);
-//            buffer.readerIndex(0);
-//            fury.serialize(buffer, simpleObject);
-//            var obj = fury.deserialize(buffer);
-//        }
-//
-//        System.out.println(StringUtils.format("[fury]     [简单对象] [thread:{}] [size:{}] [time:{}]", Thread.currentThread().getName(), buffer.writerIndex(), System.currentTimeMillis() - startTime));
-//
-//        // 序列化和反序列化常规对象
-//        startTime = System.currentTimeMillis();
-//        for (int i = 0; i < benchmark; i++) {
-//            buffer.writerIndex(0);
-//            buffer.readerIndex(0);
-//            fury.serialize(buffer, normalObject);
-//            var obj = fury.deserialize(buffer);
-//        }
-//
-//        System.out.println(StringUtils.format("[fury]     [常规对象] [thread:{}] [size:{}] [time:{}]", Thread.currentThread().getName(), buffer.writerIndex(), System.currentTimeMillis() - startTime));
-//
-//        // 序列化和反序列化复杂对象
-//        startTime = System.currentTimeMillis();
-//        for (int i = 0; i < benchmark; i++) {
-//            buffer.writerIndex(0);
-//            buffer.readerIndex(0);
-//            fury.serialize(buffer, complexObject);
-//            var obj = fury.deserialize(buffer);
-//        }
-//        System.out.println(StringUtils.format("[fury]     [复杂对象] [thread:{}] [size:{}] [time:{}]", Thread.currentThread().getName(), buffer.writerIndex(), System.currentTimeMillis() - startTime));
-//    }
-
     @Test
     public void kryoTest() {
         try {
@@ -273,17 +235,6 @@ public class BenchmarkTesting {
         countdown.await();
     }
 
-//    @Test
-//    public void furyMultipleThreadTest() throws InterruptedException {
-//        var countdown = new CountDownLatch(threadNum);
-//        for (var i = 0; i < threadNum; i++) {
-//            executors[i].execute(() -> {
-//                furyTest();
-//                countdown.countDown();
-//            });
-//        }
-//        countdown.await();
-//    }
 
     @Test
     public void kryoMultipleThreadTest() throws InterruptedException {
@@ -359,21 +310,6 @@ public class BenchmarkTesting {
         }
     }
 
-//    private static ThreadSafeFury fury;
-//
-//    static {
-//        fury = new ThreadLocalFury(classLoader -> {
-//            Fury f = Fury.builder().withLanguage(Language.JAVA)
-//                    .build();
-//            f.register(ComplexObject.class);
-//            f.register(NormalObject.class);
-//            f.register(SimpleObject.class);
-//            f.register(VeryBigObject.class);
-//            f.register(ObjectA.class);
-//            f.register(ObjectB.class);
-//            return f;
-//        });
-//    }
 
     // -------------------------------------------以下为测试用例---------------------------------------------------------------
     // 简单类型