Examples of org.codehaus.jackson.util.BufferRecycler

org.codehaus.jackson.util.BufferRecycler
This is a small utility class, whose main functionality is to allow simple reuse of raw byte/char buffers. It is usually used through ThreadLocal member of the owning class pointing to instance of this class through a SoftReference. The end result is a low-overhead GC-cleanable recycling: hopefully ideal for use by stream readers.

    request.getResponseContent().write(ByteBuffer.wrap(dataBytes));
  }


  protected JsonGenerator createJsonGenerator(ObjectCodec codec, Writer writer, boolean prettyPrint)
  {
    IOContext ioCtx = new IOContext(new BufferRecycler(), null, true);
    WriterBasedGenerator result = new WriterBasedGenerator(ioCtx, 0, codec, writer);
    result.configure(Feature.QUOTE_FIELD_NAMES, true);
    if (prettyPrint) result.useDefaultPrettyPrinter();


    return result;

View Full Code Here

     * Note: only public to give access for <code>ObjectMapper</code>
     */
    public BufferRecycler _getBufferRecycler()
    {
        SoftReference<BufferRecycler> ref = _recyclerRef.get();
        BufferRecycler br = (ref == null) ? null : ref.get();


        if (br == null) {
            br = new BufferRecycler();
            _recyclerRef.set(new SoftReference<BufferRecycler>(br));
        }
        return br;
    }

View Full Code Here

     * for parsers and generators.
     */
    protected final BufferRecycler _getBufferRecycler()
    {
        SoftReference<BufferRecycler> ref = _recyclerRef.get();
        BufferRecycler br = (ref == null) ? null : ref.get();


        if (br == null) {
            br = new BufferRecycler();
            if (ref == null) {
                _recyclerRef.set(new SoftReference<BufferRecycler>(br));
            }
        }
        return br;

View Full Code Here

    extends BaseTest
{
    public void testUtf8Issue462() throws Exception
    {
        ByteArrayOutputStream bytes = new ByteArrayOutputStream();
        IOContext ioc = new IOContext(new BufferRecycler(), bytes, true);
        JsonGenerator gen = new Utf8Generator(ioc, 0, null, bytes);
        String str = "Natuurlijk is alles gelukt en weer een tevreden klant\uD83D\uDE04";
        int length = 4000 - 38;


        for (int i = 1; i <= length; ++i) {

View Full Code Here


        //assertEquals(0, v.getPatchLevel());
    }


    private IOContext getIOContext() {
        return new IOContext(new BufferRecycler(), null, false);
    }

View Full Code Here

     * Note: only public to give access for <code>ObjectMapper</code>
     */
    public BufferRecycler _getBufferRecycler()
    {
        SoftReference<BufferRecycler> ref = _recyclerRef.get();
        BufferRecycler br = (ref == null) ? null : ref.get();


        if (br == null) {
            br = new BufferRecycler();
            _recyclerRef.set(new SoftReference<BufferRecycler>(br));
        }
        return br;
    }

View Full Code Here

public class TestUTF8Writer
    extends main.BaseTest
{
    public void testSimple() throws Exception
    {
        BufferRecycler rec = new BufferRecycler();
        IOContext ctxt = new IOContext(rec, null, false);
        ByteArrayOutputStream out = new ByteArrayOutputStream();
        UTF8Writer w = new UTF8Writer(ctxt, out);


        String str = "AB\u00A0\u1AE9\uFFFC";

View Full Code Here

public class TestIOContext
    extends main.BaseTest
{
    public void testAllocations() throws Exception
    {
        IOContext ctxt = new IOContext(new BufferRecycler(), "N/A", true);


        /* I/O Read buffer */


        // First succeeds:
        assertNotNull(ctxt.allocReadIOBuffer());

View Full Code Here

     * Note: only public to give access for <code>ObjectMapper</code>
     */
    public final BufferRecycler _getBufferRecycler()
    {
        SoftReference<BufferRecycler> ref = _recyclerRef.get();
        BufferRecycler br = (ref == null) ? null : ref.get();


        if (br == null) {
            br = new BufferRecycler();
            if (ref == null) {
                _recyclerRef.set(new SoftReference<BufferRecycler>(br));
            }
        }
        return br;

View Full Code Here

    {
        ByteArrayInputStream bin = new ByteArrayInputStream(mData);


        char[] cbuf = new char[mData.length];


        IOContext ctxt = new IOContext(new BufferRecycler(), this, false);
        int sum = 0;


        for (int i = 0; i < reps; ++i) {
            /* This may be unfair advantage (allocating buffer of exact
             * size)? But let's do that for now

View Full Code Here

TOP

Related Classes of org.codehaus.jackson.util.BufferRecycler

com.linkedin.databus2.core.container.request.AbstractRequestProcesser

org.codehaus.jackson.impl.TestUtf8Generator

org.codehaus.jackson.io.TestIOContext

org.codehaus.jackson.io.TestUTF8Writer

org.codehaus.jackson.JsonFactory

org.codehaus.jackson.version.TestVersions

TestJsonPerf

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.