Eclipse
/
jetty.project
mirror of https://github.com/jetty/jetty.project.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fixes #8007 - Support Loom. (#8465) 

Now using Executors.newVirtualThreadPerTaskExecutor() to execute
tasks, so the executor is tracked by the runtime for thread dumps, etc.

Signed-off-by: Simone Bordet <simone.bordet@gmail.com>
This commit is contained in:
Simone Bordet 2022-08-15 17:17:35 +02:00 committed by GitHub
parent 32e081566e
commit 6f0623f48d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
jetty-util/src/main/java/org/eclipse/jetty/util/VirtualThreads.java
View File

@ -15,6 +15,7 @@ package org.eclipse.jetty.util;
import java.lang.reflect.Method;
import java.util.concurrent.Executor;
import java.util.concurrent.Executors;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@ -24,20 +25,20 @@ import org.slf4j.LoggerFactory;
* and, if virtual threads are supported, to start virtual threads.</p>
*
* @see #areSupported()
* @see #startVirtualThread(Runnable)
* @see #executeOnVirtualThread(Runnable)
* @see #isVirtualThread()
*/
public class VirtualThreads
{
private static final Logger LOG = LoggerFactory.getLogger(VirtualThreads.class);
private static final Method startVirtualThread = probeStartVirtualThread();
private static final Executor executor = probeVirtualThreadExecutor();
private static final Method isVirtualThread = probeIsVirtualThread();
private static Method probeStartVirtualThread()
private static Executor probeVirtualThreadExecutor()
{
try
{
return Thread.class.getMethod("startVirtualThread", Runnable.class);
return (Executor)Executors.class.getMethod("newVirtualThreadPerTaskExecutor").invoke(null);
}
catch (Throwable x)
{
@ -67,7 +68,7 @@ public class VirtualThreads
*/
public static boolean areSupported()
{
return startVirtualThread != null;
return executor != null;
}
/**
@ -78,13 +79,13 @@ public class VirtualThreads
* @param task the task to execute in a virtual thread
* @see #areSupported()
*/
public static void startVirtualThread(Runnable task)
public static void executeOnVirtualThread(Runnable task)
{
try
{
if (LOG.isDebugEnabled())
LOG.debug("Starting in virtual thread: {}", task);
startVirtualThread.invoke(null, task);
executor.execute(task);
}
catch (Throwable x)
{

2
jetty-util/src/main/java/org/eclipse/jetty/util/thread/strategy/AdaptiveExecutionStrategy.java
View File

@ -472,7 +472,7 @@ public class AdaptiveExecutionStrategy extends ContainerLifeCycle implements Exe
try
{
if (isUseVirtualThreads())
VirtualThreads.startVirtualThread(task);
VirtualThreads.executeOnVirtualThread(task);
else
_executor.execute(task);
}