161sh/CatgirlIntelligenceAgency
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

(index-journal) Thread safe IndexJournalReadEntry

Browse Source
This commit is contained in:
Viktor Lofgren 2023-10-05 19:39:09 +02:00
parent f6e9ef6de9
commit 08e8fc6736
1 changed files with 14 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
code/features-index/index-journal/src/main/java/nu.marginalia.index/journal/reader/IndexJournalReadEntry.java
View File

@ -21,8 +21,16 @@ public class IndexJournalReadEntry {
}
static final byte[] bytes = new byte[8*65536];
static final LongBuffer longBuffer = ByteBuffer.wrap(bytes).asLongBuffer();
record WorkArea(byte[] bytes, LongBuffer buffer) {
WorkArea(byte[] bytes) {
this(bytes, ByteBuffer.wrap(bytes).asLongBuffer());
}
WorkArea() {
this(new byte[8*65536]);
}
}
static ThreadLocal<WorkArea> pool = ThreadLocal.withInitial(WorkArea::new);
public static IndexJournalReadEntry read(DataInputStream inputStream) throws IOException {
@ -36,12 +44,14 @@ public class IndexJournalReadEntry {
docId,
meta);
inputStream.readFully(bytes, 0, 8*header.entrySize());
var workArea = pool.get();
inputStream.readFully(workArea.bytes, 0, 8 * header.entrySize());
long[] out = new long[header.entrySize()];
longBuffer.get(0, out, 0, out.length);
workArea.buffer.get(0, out, 0, out.length);
return new IndexJournalReadEntry(header, out);
}
public long docId() {