test/jdk/java/lang/Thread/virtual/JfrEvents.java

@@ -97,10 +97,50 @@
              assertEquals(100, startCount);
              assertEquals(100, endCount);
          }
      }
  
+     /**
+      * Test jdk.VirtualThreadPark.
+      */
+     @ParameterizedTest
+     @ValueSource(longs = { 0, 30_000_000_000L, Long.MAX_VALUE })
+     void testPark(long timeout) throws Exception {
+         try (Recording recording = new Recording()) {
+             recording.enable("jdk.VirtualThreadPark");
+ 
+             recording.start();
+ 
+             var started = new AtomicBoolean();
+             var done = new AtomicBoolean();
+             var vthread = Thread.startVirtualThread(() -> {
+                 started.set(true);
+                 while (!done.get()) {
+                     if (timeout > 0) {
+                         LockSupport.parkNanos(timeout);
+                     } else {
+                         LockSupport.park();
+                     }
+                 }
+             });
+ 
+             try {
+                 // wait for thread to start and park
+                 awaitTrue(started);
+                 await(vthread, timeout > 0 ? Thread.State.TIMED_WAITING : Thread.State.WAITING);
+             } finally {
+                 done.set(true);
+                 LockSupport.unpark(vthread);
+                 vthread.join();
+                 recording.stop();
+             }
+ 
+             assertContainsParkEvent(recording, vthread, timeout);
+         }
+ 
+     }
+ 
      /**
       * Test jdk.VirtualThreadPinned event when parking while pinned.
       */
      @ParameterizedTest
      @ValueSource(booleans = { true, false })

@@ -452,10 +492,34 @@
          assertTrue(pinnedEvents.stream()
                          .anyMatch(e -> e.getThread().getJavaThreadId() == tid),
                  "jdk.VirtualThreadPinned for javaThreadId = " + tid + " not found");
      }
  
+     /**
+      * Assert that a recording contains a jdk.VirtualThreadPark event on the given thread.
+      */
+     private void assertContainsParkEvent(Recording recording,
+                                          Thread thread,
+                                          long testTimeout) throws IOException {
+         List<RecordedEvent> allParkEvents = find(recording, "jdk.VirtualThreadPark");
+         assertTrue(allParkEvents.size() > 0, "No jdk.VirtualThreadPark events in recording");
+         System.err.println(allParkEvents);
+ 
+         // park events for the given thread
+         long tid = thread.threadId();
+         List<RecordedEvent> parkEvents = allParkEvents.stream()
+                 .filter(e -> e.getThread().getJavaThreadId() == tid)
+                 .toList();
+ 
+         long expectedTimeout = (testTimeout != 0) ? testTimeout : Long.MIN_VALUE;
+         boolean found = parkEvents.stream()
+                 .map(e -> e.getLong("timeout"))
+                 .allMatch(t -> t == expectedTimeout);
+         assertTrue(found, "jdk.VirtualThreadPark for javaThreadId = " + tid
+                 + ", timeout = " + expectedTimeout + " not found");
+     }
+ 
      /**
       * Waits for the given boolean to be set to true.
       */
      private void awaitTrue(AtomicBoolean b) throws InterruptedException {
          while (!b.get()) {