honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

move to use linked blocking queue

This commit is contained in:
Shay Banon 2012-07-12 11:28:55 +02:00
parent 51ff83942c
commit 0cebcc56a4
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/main/java/org/apache/lucene/store/bytebuffer/CachingByteBufferAllocator.java
View File

@ -19,7 +19,8 @@ package org.apache.lucene.store.bytebuffer;
import java.io.IOException; import java.io.IOException;
import java.nio.ByteBuffer; import java.nio.ByteBuffer;
import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
/** /**
* The caching byte buffer allocator allows to define a global size for both the small and large buffers * The caching byte buffer allocator allows to define a global size for both the small and large buffers
@ -27,8 +28,8 @@ import java.util.concurrent.ArrayBlockingQueue;
*/ */
public class CachingByteBufferAllocator extends PlainByteBufferAllocator { public class CachingByteBufferAllocator extends PlainByteBufferAllocator {
private final ArrayBlockingQueue<ByteBuffer> smallCache; private final BlockingQueue<ByteBuffer> smallCache;
private final ArrayBlockingQueue<ByteBuffer> largeCache; private final BlockingQueue<ByteBuffer> largeCache;
/** /**
* @param direct If set to true, will allocate direct buffers (off heap). * @param direct If set to true, will allocate direct buffers (off heap).
@ -40,8 +41,8 @@ public class CachingByteBufferAllocator extends PlainByteBufferAllocator {
public CachingByteBufferAllocator(boolean direct, int smallBufferSizeInBytes, int largeBufferSizeInBytes, public CachingByteBufferAllocator(boolean direct, int smallBufferSizeInBytes, int largeBufferSizeInBytes,
int smallCacheSizeInBytes, int largeCacheSizeInBytes) { int smallCacheSizeInBytes, int largeCacheSizeInBytes) {
super(direct, smallBufferSizeInBytes, largeBufferSizeInBytes); super(direct, smallBufferSizeInBytes, largeBufferSizeInBytes);
this.smallCache = new ArrayBlockingQueue<ByteBuffer>(smallCacheSizeInBytes / smallBufferSizeInBytes); this.smallCache = new LinkedBlockingQueue<ByteBuffer>(smallCacheSizeInBytes / smallBufferSizeInBytes);
this.largeCache = new ArrayBlockingQueue<ByteBuffer>(largeCacheSizeInBytes / largeBufferSizeInBytes); this.largeCache = new LinkedBlockingQueue<ByteBuffer>(largeCacheSizeInBytes / largeBufferSizeInBytes);
} }