diff --git a/src/main/java/it/cavallium/dbengine/lucene/LMDBArray.java b/src/main/java/it/cavallium/dbengine/lucene/LMDBArray.java
index 189b56e..e78c154 100644
--- a/src/main/java/it/cavallium/dbengine/lucene/LMDBArray.java
+++ b/src/main/java/it/cavallium/dbengine/lucene/LMDBArray.java
@@ -244,6 +244,14 @@ public class LMDBArray<V> implements IArray<V>, Closeable {
 	public void close() throws IOException {
 		if (closed.compareAndSet(false, true)) {
 			ensureThread();
+			for (ByteBuf toWriteKey : toWriteKeys) {
+				toWriteKey.release();
+			}
+			for (ByteBuf toWriteValue : toWriteValues) {
+				toWriteValue.release();
+			}
+			toWriteKeys.clear();
+			toWriteValues.clear();
 			if (rwTxn != null) {
 				rwTxn.close();
 			}
diff --git a/src/main/java/it/cavallium/dbengine/lucene/LMDBPriorityQueue.java b/src/main/java/it/cavallium/dbengine/lucene/LMDBPriorityQueue.java
index bb908f5..f2b3546 100644
--- a/src/main/java/it/cavallium/dbengine/lucene/LMDBPriorityQueue.java
+++ b/src/main/java/it/cavallium/dbengine/lucene/LMDBPriorityQueue.java
@@ -498,6 +498,14 @@ public class LMDBPriorityQueue<T> implements PriorityQueue<T>, Reversable<Revers
 	public void close() throws IOException {
 		if (closed.compareAndSet(false, true)) {
 			ensureThread();
+			for (ByteBuf toWriteKey : toWriteKeys) {
+				toWriteKey.release();
+			}
+			for (ByteBuf toWriteValue : toWriteValues) {
+				toWriteValue.release();
+			}
+			toWriteKeys.clear();
+			toWriteValues.clear();
 			if (cur != null) {
 				cur.close();
 			}