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 @@
test
-
-
-
-
-
-
-
-
-
-
-
-
-
junit
junit
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;
-// });
-// }
// -------------------------------------------以下为测试用例---------------------------------------------------------------
// 简单类型