Update ConcurrentReaderWriter.java

ponder-lab · Aug 8, 2024 · f433ad3 · f433ad3
1 parent 9981865
commit f433ad3
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/src/test/java/edu/illinois/library/cantaloupe/test/ConcurrentReaderWriter.java b/src/test/java/edu/illinois/library/cantaloupe/test/ConcurrentReaderWriter.java
@@ -34,7 +34,7 @@ public ConcurrentReaderWriter(Callable<Void> writer, Callable<Void> reader,
 
     public void run() throws Exception {
         for (int i = 0; i < numThreads / 2f; i++) {
-            new Thread(() -> { // writer thread
+            Thread.ofVirtual().start(() -> { // writer thread
                 try {
                     writer.call();
                 } catch (Exception e) {
@@ -43,9 +43,9 @@ public void run() throws Exception {
                 } finally {
                     writeCount.incrementAndGet();
                 }
-            }).start();
+            });
 
-            new Thread(() -> {
+            Thread.ofVirtual().start(() -> {
                 while (true) {
                     // Spin until we have something to read.
                     if (writeCount.get() > 0) {
@@ -62,7 +62,7 @@ public void run() throws Exception {
                         sleep(1);
                     }
                 }
-            }).start();
+            });
         }
 
         while (readCount.get() < numThreads / 2f ||