provoke error using CDL instead of timer

Author: overheadhunter

src/test/java/org/cryptomator/cryptofs/CryptoFileChannelWriteReadIntegrationTest.java

@@ -51,6 +51,7 @@
 import java.util.Random;
 import java.util.Set;
 import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicBoolean;
@@ -617,13 +618,14 @@ public void testWriteThenDeleteThenRead() throws IOException {
 			Assertions.assertEquals(-1, bytesRead);
 		}
 
-		@RepeatedTest(10)
-		void testConcurrentWriteAndTruncate() throws IOException, InterruptedException {
+		@RepeatedTest(50)
+		public void testConcurrentWriteAndTruncate() throws IOException, InterruptedException {
 			AtomicBoolean keepWriting = new AtomicBoolean(true);
-			ByteBuffer buf = ByteBuffer.wrap("the quick brown fox jumps over the lazy dog".getBytes(StandardCharsets.UTF_8));
-			var timer = new CountDownLatch(1);
-			var executor = Executors.newCachedThreadPool();
-			try (FileChannel writingChannel = FileChannel.open(file, WRITE, CREATE)) {
+			ByteBuffer buf = ByteBuffer.allocate(50_000); // 50 kiB
+
+			try (ExecutorService executor = Executors.newCachedThreadPool();
+				 FileChannel writingChannel = FileChannel.open(file, WRITE, CREATE)) {
+				var cdl = new CountDownLatch(3);
 				executor.submit(() -> {
 					while (keepWriting.get()) {
 						try {
@@ -632,21 +634,22 @@ void testConcurrentWriteAndTruncate() throws IOException, InterruptedException {
 							throw new UncheckedIOException(e);
 						}
 						buf.flip();
+						cdl.countDown();
 					}
 				});
-				timer.await(500, TimeUnit.MILLISECONDS);
+				cdl.await();
 				try (FileChannel truncatingChannel = FileChannel.open(file, WRITE, TRUNCATE_EXISTING)) {
 					keepWriting.set(false);
 				}
-				executor.shutdown();
 			}
 
-			Assertions.assertDoesNotThrow(() -> {
-				try (FileChannel readingChannel = FileChannel.open(file, READ)) {
-					var dst = ByteBuffer.allocate(buf.capacity());
+
+			try (FileChannel readingChannel = FileChannel.open(file, READ)) {
+				var dst = ByteBuffer.allocate(buf.capacity());
+				Assertions.assertDoesNotThrow(() -> {
 					readingChannel.read(dst);
-				}
-			});
+				});
+			}
 		}
 
 	}