- more synchronization

lukas.molzberger · lukas.molzberger · commit da1b3fe33d9e · 2024-03-20T07:48:40.000+01:00
diff --git a/core/src/main/java/network/aika/Model.java b/core/src/main/java/network/aika/Model.java
@@ -83,19 +83,25 @@ public long createNeuronId() {
     }
 
     public Long getLowestDocumentId() {
-        try {
-            return documents.firstKey();
-        } catch (NoSuchElementException e) {
-            return null;
+        synchronized (documents) {
+            try {
+                return documents.firstKey();
+            } catch (NoSuchElementException e) {
+                return null;
+            }
         }
     }
 
     public void registerDocument(Document doc) {
-        documents.put(doc.getId(), doc);
+        synchronized (documents) {
+            documents.put(doc.getId(), doc);
+        }
     }
 
     public void deregisterDocument(Document doc) {
-        documents.remove(doc.getId());
+        synchronized (documents) {
+            documents.remove(doc.getId());
+        }
 
         lastProcessedDocument = Math.max(lastProcessedDocument, doc.getId());
     }

Original file line number	Diff line number	Diff line change
`@@ -83,19 +83,25 @@ public long createNeuronId() {`
`83`	`83`	`}`
`84`	`84`
`85`	`85`	`public Long getLowestDocumentId() {`
`86`		`- try {`
`87`		`- return documents.firstKey();`
`88`		`- } catch (NoSuchElementException e) {`
`89`		`- return null;`
	`86`	`+ synchronized (documents) {`
	`87`	`+ try {`
	`88`	`+ return documents.firstKey();`
	`89`	`+ } catch (NoSuchElementException e) {`
	`90`	`+ return null;`
	`91`	`+ }`
`90`	`92`	`}`
`91`	`93`	`}`
`92`	`94`
`93`	`95`	`public void registerDocument(Document doc) {`
`94`		`- documents.put(doc.getId(), doc);`
	`96`	`+ synchronized (documents) {`
	`97`	`+ documents.put(doc.getId(), doc);`
	`98`	`+ }`
`95`	`99`	`}`
`96`	`100`
`97`	`101`	`public void deregisterDocument(Document doc) {`
`98`		`- documents.remove(doc.getId());`
	`102`	`+ synchronized (documents) {`
	`103`	`+ documents.remove(doc.getId());`
	`104`	`+ }`
`99`	`105`
`100`	`106`	`lastProcessedDocument = Math.max(lastProcessedDocument, doc.getId());`
`101`	`107`	`}`