qwe

Author: kaspernielsen

modules/packed-incubator/packed-incubator-concurrent/src/main/java/app/packed/concurrent/Daemon.java

@@ -34,5 +34,5 @@
 
     boolean interruptOnStop() default false;
 
-    boolean useVirtual() default false;
+    ThreadKind threadKind() default ThreadKind.PLATFORM_THREAD;
 }

modules/packed-incubator/packed-incubator-concurrent/src/main/java/app/packed/concurrent/ThreadExtension.java

@@ -130,7 +130,7 @@ public void onAnnotatedMethod(Annotation hook, BeanIntrospector.OnMethod on) {
                     DaemonOperationHandle h = on.newOperation(DAEMON_OPERATION_TEMPLATE).install(namespace, DaemonOperationHandle::new);
 
                     // Configure the handle
-                    h.useVirtual = daemon.useVirtual();
+                    h.useVirtual = daemon.threadKind() == ThreadKind.VIRTUAL_THREAD;
                 } else {
                     super.onAnnotatedMethod(hook, on);
                 }

modules/packed-incubator/packed-incubator-concurrent/src/main/java/app/packed/concurrent/ThreadKind.java

@@ -0,0 +1,23 @@
+/*
+ * Copyright (c) 2008 Kasper Nielsen.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package app.packed.concurrent;
+
+/**
+ *
+ */
+public enum ThreadKind {
+    PLATFORM_THREAD, VIRTUAL_THREAD
+}