experiment

Author: tpietzsch

src/main/java/org/janelia/saalfeldlab/n5/KeyLockState.java

@@ -173,6 +173,7 @@ private void releaseFileLock() {
 
     void releaseLock() {
 
+		System.out.println("KeyLockState.releaseLock");
         final boolean isWrite = threadLock.isWriteLockedByCurrentThread();
 
         synchronized (this) {
@@ -181,6 +182,7 @@ void releaseLock() {
                 releaseFileLock();
             } else {
                 readLockHolders--;
+				System.out.println("  readLockHolders = " + readLockHolders);
                 if (readLockHolders == 0) {
                     releaseFileLock();
                 }

src/test/java/org/janelia/saalfeldlab/n5/FileKeyLockManagerTest.java

@@ -76,6 +76,33 @@ public void tearDown() throws IOException {
 		}
 	}
 
+	private void lockunlock(final Path testFile) throws IOException {
+		LockedChannel lock1 = FILE_LOCK_MANAGER.lockForReading(testFile);
+		lock1.close();
+	}
+
+	@Test
+	public void testCleanup() throws Exception {
+		/* create a test file */
+		final Path testFile = tempDir.resolve("test.txt");
+		final String testContent = "test";
+		Files.write(testFile, testContent.getBytes());
+
+		LockedChannel lock1 = FILE_LOCK_MANAGER.lockForReading(testFile);
+		LockedChannel lock2 = FILE_LOCK_MANAGER.lockForReading(testFile);
+		System.out.println("lock1.close");
+		lock1.close();
+		lock1 = null;
+		for (int i = 0; i < 10; i++) {
+			System.out.println("lockunlock");
+			lockunlock(testFile);
+			System.gc();
+			Thread.sleep(500);
+		}
+		System.out.println("lock2.close");
+		lock2.close();
+	}
+
 	@Test
 	public void testConcurrentReads() throws Exception {