Skip to content

Commit

Permalink
increase queue size of import thread
Browse files Browse the repository at this point in the history
  • Loading branch information
lonvia committed Dec 3, 2024
1 parent 6299b3b commit 0ee2903
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/main/java/de/komoot/photon/nominatim/ImportThread.java
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ class ImportThread {

private static final int PROGRESS_INTERVAL = 50000;
private static final NominatimResult FINAL_DOCUMENT = new NominatimResult(new PhotonDoc(0, null, 0, null, null));
private final BlockingQueue<NominatimResult> documents = new LinkedBlockingDeque<>(20);
private final BlockingQueue<NominatimResult> documents = new LinkedBlockingDeque<>(10000);
private final AtomicLong counter = new AtomicLong();
private final Importer importer;
private final Thread thread;
Expand Down

0 comments on commit 0ee2903

Please sign in to comment.