QuickBuffers 1.4 (#93)

build.gradle

@@ -96,6 +96,8 @@ dependencies {
  implementation group: 'com.github.javadev', name: 'underscore', version: '1.97'
  // yasson
  implementation group: 'org.eclipse', name: 'yasson', version: '3.0.3'
+ // QuickBuffers
+ implementation group: 'us.hebi.quickbuf', name: 'quickbuf-runtime', version: '1.4'
 
  // Test
  testImplementation group: 'junit', name: 'junit', version: '4.13.2'

src/main/java/com/github/fabienrenaud/jjb/JsonBench.java

@@ -130,4 +130,9 @@ public Object qson() throws Exception {
  public Object antons() throws Exception {
  return null;
  }
+
+ public Object quickbuf_json() throws Exception {
+ return null;
+ }
+
 }

src/main/java/com/github/fabienrenaud/jjb/data/JsonSource.java

@@ -8,6 +8,7 @@
 import okio.BufferedSource;
 import okio.ForwardingSource;
 import okio.Okio;
+import us.hebi.quickbuf.ProtoMessage;
 
 import java.io.ByteArrayInputStream;
 import java.io.InputStream;
@@ -21,6 +22,7 @@ public abstract class JsonSource<T> {
  private final T[] jsonAsObject;
  private final String[] jsonAsString;
  private final byte[][] jsonAsBytes;
+ private final ProtoMessage<?>[] jsonAsQuickbufObject;
  private final ThreadLocal<ByteArrayInputStream[]> jsonAsByteArrayInputStream;
 
  private final DataGenerator<T> dataGenerator;
@@ -33,6 +35,7 @@ public abstract class JsonSource<T> {
  this.jsonAsObject = newPojoArray(quantity);
  this.jsonAsString = new String[quantity];
  this.jsonAsBytes = new byte[quantity][];
+ this.jsonAsQuickbufObject = new ProtoMessage<?>[quantity];
 
  this.dataGenerator = dataGenerator;
  this.streamSerializer = streamSerializer;
@@ -58,6 +61,8 @@ private void populateFields(int quantity, int individualSize) {
  String json = provider.jackson().writeValueAsString(obj);
  jsonAsString[i] = json;
  jsonAsBytes[i] = json.getBytes();
+ jsonAsQuickbufObject[i] = provider().quickbufPojo().clearQuick().clone().mergeFrom(
+ us.hebi.quickbuf.JsonSource.newInstance(jsonAsBytes[i]).setIgnoreUnknownFields(false));
  }
  } catch (Exception ex) {
  ex.printStackTrace();
@@ -100,6 +105,10 @@ public T nextPojo() {
  return jsonAsObject[index(jsonAsObject.length)];
  }
 
+ public ProtoMessage<?> nextQuickbufPojo() {
+ return jsonAsQuickbufObject[index(jsonAsQuickbufObject.length)];
+ }
+
  public StreamSerializer<T> streamSerializer() {
  return streamSerializer;
  }

src/main/java/com/github/fabienrenaud/jjb/databind/Deserialization.java

@@ -136,4 +136,12 @@ public Object moshi() throws Exception {
  public Object qson() throws Exception {
  return JSON_SOURCE().provider().qson().read(JSON_SOURCE().nextByteArray(), JSON_SOURCE().pojoType());
  }
+
+ @Benchmark
+ @Override
+ public Object quickbuf_json() throws Exception {
+ return JSON_SOURCE().provider().quickbufPojo().clearQuick()
+ .mergeFrom(us.hebi.quickbuf.JsonSource.newInstance(JSON_SOURCE().nextByteArray()));
+ }
+
 }

src/main/java/com/github/fabienrenaud/jjb/databind/Serialization.java

@@ -168,4 +168,11 @@ public Object qson() throws Exception {
  JSON_SOURCE().provider().qson().writeStream(JSON_SOURCE().nextPojo(), baos);
  return baos;
  }
+
+ @Benchmark
+ @Override
+ public Object quickbuf_json() throws Exception {
+ return JSON_SOURCE().provider().quickbufSink().clear().writeMessage(JSON_SOURCE().nextQuickbufPojo());
+ }
+
 }