Future.await should interrupt the current thread when the worker exec…

…utor is closed.

Motivation:

Future.await incorrectly performs a no-op when the worker executor is closed (returns a null latch), which reports a failure that might not exist.

Changes:

When the worker executor returns null, throw an interrupted exception.

src/main/java/io/vertx/core/Future.java

@@ -683,9 +683,12 @@ static <T> T await(Future<T> future) {
     }
     if (future.succeeded()) {
       return future.result();
-    } else {
+    } else if (future.failed()) {
       Utils.throwAsUnchecked(future.cause());
       return null;
+    } else {
+      Utils.throwAsUnchecked(new InterruptedException("Context closed"));
+      return null;
     }
   }
 

src/test/java/io/vertx/core/VirtualThreadContextTest.java

@@ -349,4 +349,31 @@ public void testContextCloseContextSerialization() throws Exception {
     }
     f.toCompletionStage().toCompletableFuture().get(20, TimeUnit.SECONDS);
   }
+
+  @Test
+  public void testAwaitWhenClosed() throws Exception {
+    Assume.assumeTrue(isVirtualThreadAvailable());
+    ContextInternal ctx = vertx.createVirtualThreadContext();
+    CountDownLatch latch = new CountDownLatch(1);
+    ctx.runOnContext(v -> {
+      latch.countDown();
+      try {
+        new CountDownLatch(1).await();
+        fail();
+      } catch (InterruptedException expected) {
+        assertFalse(Thread.currentThread().isInterrupted());
+      }
+      try {
+        Promise.promise().future().await();
+        fail();
+      } catch (Exception e) {
+        assertEquals(InterruptedException.class, e.getClass());
+        testComplete();
+      }
+    });
+    awaitLatch(latch);
+    // Interrupts virtual thread
+    ctx.close();
+    await();
+  }
 }