lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

AnonymousVirtuals

Browse Source
This commit is contained in:
redkale
2024-10-09 21:32:46 +08:00
parent 21c00b3419
commit 0d84ef0541
2 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/org/redkale/util/Jdk21Inners.java → src/main/java/org/redkale/util/AnonymousVirtuals.java
View File

@@ -15,14 +15,14 @@ import java.util.function.Supplier;
* *
* @author zhangjx * @author zhangjx
*/ */
class Jdk21Inners { class AnonymousVirtuals {
static { static {
// 加载时进行可用性判断 // 加载时进行可用性判断
Thread.currentThread().isVirtual(); Thread.currentThread().isVirtual();
} }
private Jdk21Inners() { private AnonymousVirtuals() {
// do nothing // do nothing
} }

12
src/main/java/org/redkale/util/Utility.java
View File

@@ -122,16 +122,16 @@ public final class Utility {
private static final Executor defaultExecutorConsumer = Runnable::run; private static final Executor defaultExecutorConsumer = Runnable::run;
// org.redkale.util.JDK21VirtualThreadLocal // org.redkale.util.AnonymousVirtuals.VirtualThreadLocal
private static final Function<Supplier, ThreadLocal> virtualThreadLocalFunction; private static final Function<Supplier, ThreadLocal> virtualThreadLocalFunction;
// org.redkale.util.JDK21VirtualThreadFactory // org.redkale.util.AnonymousVirtuals.VirtualThreadFactory
private static final Function<String, ThreadFactory> virtualThreadFactoryFunction; private static final Function<String, ThreadFactory> virtualThreadFactoryFunction;
// org.redkale.util.JDK21VirtualPoolFunction // org.redkale.util.AnonymousVirtuals.VirtualPoolFunction
private static final Function<String, ExecutorService> virtualPoolFunction; private static final Function<String, ExecutorService> virtualPoolFunction;
// org.redkale.util.JDK21VirtualExecutor // org.redkale.util.AnonymousVirtuals.VirtualExecutor
private static final Executor virtualExecutorConsumer; private static final Executor virtualExecutorConsumer;
// org.redkale.util.SignalShutDown // org.redkale.util.SignalShutDown
@@ -180,8 +180,8 @@ public final class Utility {
Consumer<Consumer<String>> signalShutdownConsumer0 = null; Consumer<Consumer<String>> signalShutdownConsumer0 = null;
final ClassLoader loader = Thread.currentThread().getContextClassLoader(); final ClassLoader loader = Thread.currentThread().getContextClassLoader();
try { // Jdk21Inners try { // AnonymousVirtuals
String virtualName = "org.redkale.util.Jdk21Inners"; String virtualName = "org.redkale.util.AnonymousVirtuals";
Class virtualClazz = loader.loadClass(virtualName); Class virtualClazz = loader.loadClass(virtualName);
Method method = virtualClazz.getMethod("createExecutor"); Method method = virtualClazz.getMethod("createExecutor");
virtualExecutorConsumer0 = (Executor) method.invoke(null); virtualExecutorConsumer0 = (Executor) method.invoke(null);