|
| 1 | +package com.jsoniter.benchmark.with_10_double_fields; |
| 2 | + |
| 3 | +import com.jsoniter.benchmark.All; |
| 4 | +import org.apache.thrift.TException; |
| 5 | +import org.apache.thrift.TSerializer; |
| 6 | +import org.apache.thrift.protocol.TCompactProtocol; |
| 7 | +import org.apache.thrift.protocol.TProtocol; |
| 8 | +import org.apache.thrift.transport.TIOStreamTransport; |
| 9 | +import org.junit.Test; |
| 10 | +import org.openjdk.jmh.Main; |
| 11 | +import org.openjdk.jmh.annotations.*; |
| 12 | +import org.openjdk.jmh.infra.BenchmarkParams; |
| 13 | +import org.openjdk.jmh.infra.Blackhole; |
| 14 | +import org.openjdk.jmh.runner.RunnerException; |
| 15 | + |
| 16 | +import java.io.ByteArrayOutputStream; |
| 17 | +import java.io.IOException; |
| 18 | + |
| 19 | +/* |
| 20 | +Benchmark Mode Cnt Score Error Units |
| 21 | +SerThrift.ser thrpt 5 2093533.015 ± 61061.517 ops/s |
| 22 | + */ |
| 23 | +@State(Scope.Thread) |
| 24 | +public class SerThrift { |
| 25 | + |
| 26 | + private ThriftTestObject testObject; |
| 27 | + private ByteArrayOutputStream byteArrayOutputStream; |
| 28 | + private TProtocol protocol; |
| 29 | + |
| 30 | + @Setup(Level.Trial) |
| 31 | + public void benchSetup(BenchmarkParams params) throws TException { |
| 32 | + testObject = new ThriftTestObject(); |
| 33 | + testObject.setField1(31.415926); |
| 34 | + testObject.setField2(61.415923); |
| 35 | + testObject.setField3(31.415269); |
| 36 | + testObject.setField4(53.141926); |
| 37 | + testObject.setField5(13.145926); |
| 38 | + testObject.setField6(43.115926); |
| 39 | + testObject.setField7(31.419265); |
| 40 | + testObject.setField8(23.141596); |
| 41 | + testObject.setField9(43.161592); |
| 42 | + testObject.setField10(0.112); |
| 43 | + byteArrayOutputStream = new ByteArrayOutputStream(); |
| 44 | + TCompactProtocol.Factory protocolFactory = new TCompactProtocol.Factory(); |
| 45 | + protocol = protocolFactory.getProtocol(new TIOStreamTransport(byteArrayOutputStream)); |
| 46 | + } |
| 47 | + |
| 48 | + @Test |
| 49 | + public void test() throws TException { |
| 50 | + byte[] output = new TSerializer(new TCompactProtocol.Factory()).serialize(testObject); |
| 51 | + System.out.println(output.length); |
| 52 | + } |
| 53 | + |
| 54 | + @Benchmark |
| 55 | + public void ser(Blackhole bh) throws TException { |
| 56 | + byteArrayOutputStream.reset(); |
| 57 | + testObject.write(protocol); |
| 58 | + bh.consume(byteArrayOutputStream); |
| 59 | + } |
| 60 | + |
| 61 | + public static void main(String[] args) throws IOException, RunnerException { |
| 62 | + All.loadJMH(); |
| 63 | + Main.main(new String[]{ |
| 64 | + "with_10_double_fields.SerThrift", |
| 65 | + "-i", "5", |
| 66 | + "-wi", "5", |
| 67 | + "-f", "1", |
| 68 | + }); |
| 69 | + } |
| 70 | +} |
0 commit comments