Eclipse
/
jetty.project
mirror of https://github.com/jetty/jetty.project.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Implemented buffer pooling.

This commit is contained in:
Simone Bordet 2012-03-05 16:41:35 +01:00
parent 194dcb7bc9
commit c2abdfb2e2
1 changed files with 16 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
spdy-core/src/main/java/org/eclipse/jetty/spdy/StandardByteBufferPool.java
View File

@ -19,6 +19,7 @@ package org.eclipse.jetty.spdy;
import java.nio.ByteBuffer;
import java.util.Queue;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.ConcurrentMap;
public class StandardByteBufferPool implements ByteBufferPool
@ -61,21 +62,21 @@ public class StandardByteBufferPool implements ByteBufferPool
public void release(ByteBuffer buffer)
{
// int bucket = bucketFor(buffer.capacity());
// ConcurrentMap<Integer, Queue<ByteBuffer>> buffers = buffersFor(buffer.isDirect());
//
// // Avoid to create a new queue every time, just to be discarded immediately
// Queue<ByteBuffer> byteBuffers = buffers.get(bucket);
// if (byteBuffers == null)
// {
// byteBuffers = new ConcurrentLinkedQueue<>();
// Queue<ByteBuffer> existing = buffers.putIfAbsent(bucket, byteBuffers);
// if (existing != null)
// byteBuffers = existing;
// }
//
// buffer.clear();
// byteBuffers.offer(buffer);
int bucket = bucketFor(buffer.capacity());
ConcurrentMap<Integer, Queue<ByteBuffer>> buffers = buffersFor(buffer.isDirect());
// Avoid to create a new queue every time, just to be discarded immediately
Queue<ByteBuffer> byteBuffers = buffers.get(bucket);
if (byteBuffers == null)
{
byteBuffers = new ConcurrentLinkedQueue<>();
Queue<ByteBuffer> existing = buffers.putIfAbsent(bucket, byteBuffers);
if (existing != null)
byteBuffers = existing;
}
buffer.clear();
byteBuffers.offer(buffer);
}
public void clear()