increase the buffer between ingestion and insertion thread
I was finally able to show that there is a tiny but measureable effect of this buffer. I think it was not visible before, because the parsing was too slow. But now, that I replaced the date parser, the ingestion thread is twice as fast as the insertion thread. Therefore the buffer makes more sense.
This commit is contained in:
@@ -121,7 +121,7 @@ public class TcpIngestor implements Ingestor, AutoCloseable, DisposableBean {
|
|||||||
@Override
|
@Override
|
||||||
public void start() throws Exception {
|
public void start() throws Exception {
|
||||||
|
|
||||||
final ArrayBlockingQueue<Entry> queue = new ArrayBlockingQueue<>(100);
|
final ArrayBlockingQueue<Entry> queue = new ArrayBlockingQueue<>(10_000);
|
||||||
|
|
||||||
serverThreadPool.submit(() -> {
|
serverThreadPool.submit(() -> {
|
||||||
Thread.currentThread().setName("db-ingestion");
|
Thread.currentThread().setName("db-ingestion");
|
||||||
|
|||||||
Reference in New Issue
Block a user