java - Avro 序列化 : which parts are and aren't thread-safe?

Question

我在网上的不同地方看到了一些关于此的相互矛盾的信息，因此希望真正知道的人提供权威的回答。

假设，我正在将一些东西序列化为 avro:

    class StuffToAvro {
       private final Schema schema;
       StuffToAvro(Schema schema) { this.schema = schema }

       void apply(GenericRecord stuff, OutputStream out) {
         final Encoder encoder = EncoderFactory.get.binaryEncoder(out, null);
         final GenericDatumWriter writer = new GenericDatumWriter(schema);
         writer.write(stuff, encoder):
       }
    }

问题是我是否可以/应该通过重用编码器和编写器来优化它，如果应该的话，正确的方法是什么:我可以直接初始化编写器并使其成为final 例如，还是它需要是 ThreadLocal？

关于编码器的类似问题:我应该记住之前的实例并将其传递给 getBinaryEncoder 以重用，还是也需要是 ThreadLocal。

在每种情况下，如果答案是ThreadLocal，我还想知道这样的优化是否值得复杂性:每次创建一个全新的编写器和/或编码器是否真的很昂贵时间而不是重复使用它们？

另外，我假设，无论我在这里得到什么答案，也适用于阅读/解码。是吗？

感谢任何指点。

谢谢!

Answer 1

根据这个post

Yes, a DatumReader instance may be used in multiple threads. Encoder and Decoder are not thread-safe, but DatumReader and DatumWriter are.

Writer 也是线程安全的。

Yes, re-using a single GenericDatumWriter to write multiple objects should improve performance.