tiennm99/zfoo
1
0
Fork 0
mirror of https://github.com/tiennm99/zfoo.git synced 2026-08-23 18:25:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

perf[protocol]: memory copy for int list

Browse Source
This commit is contained in:
godotg
2023-11-17 17:09:40 +08:00
parent 72bc89b0b8
commit 4881edbd67
1 changed files with 17 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
protocol/src/main/java/com/zfoo/protocol/buffer/CustomByteBuf.java
+17 -2
View File
@@ -12,10 +12,13 @@
package com.zfoo.protocol.buffer;
import com.zfoo.protocol.collection.ArrayListInt;
import com.zfoo.protocol.collection.ArrayUtils;
import com.zfoo.protocol.collection.CollectionUtils;
import io.netty.buffer.ByteBuf;
import java.nio.ByteBuffer;
import java.util.List;
/**
* 自定义协议格式，可以针对某些特定场景对做特定优化
@@ -55,7 +58,7 @@ public abstract class CustomByteBuf {
}
// 针对于int数组提高性能的复杂方式
public static void writeIntArrayComplex(ByteBuf byteBuf, int[] array) {
public static void writeIntArrayMemoryCopy(ByteBuf byteBuf, int[] array) {
if (array == null) {
byteBuf.writeByte(0);
return;
@@ -69,7 +72,7 @@ public abstract class CustomByteBuf {
byteBuf.writeBytes(byteBuffer);
}
public static int[] readIntArrayComplex(ByteBuf byteBuf) {
public static int[] readIntArrayMemoryCopy(ByteBuf byteBuf) {
var length = ByteBufUtils.readInt(byteBuf);
var byteBuffer = ByteBuffer.allocate(length * 4);
byteBuf.readBytes(byteBuffer);
@@ -80,4 +83,16 @@ public abstract class CustomByteBuf {
return ints;
}
public static void writeIntListMemoryCopy(ByteBuf byteBuf, List<Integer> list) {
if (list == null) {
byteBuf.writeByte(0);
return;
}
var array = ArrayUtils.intToArray(list);
writeIntArrayMemoryCopy(byteBuf, array);
}
public static List<Integer> readIntListMemoryCopy(ByteBuf byteBuf) {
return new ArrayListInt(readIntArrayMemoryCopy(byteBuf));
}
}