updated docs

docs/guide/src/docs/asciidoc/usage.adoc

@@ -221,10 +221,16 @@ You can override the default scheduler (`TaskExecutors.SCHEDULED`) by setting th
 [source,yaml]
 .Setting the Default Scheduler
 ----
-include::{root-dir}/libs/micronaut-worker/src/test/resources/application-virtual.yml[]
+include::{root-dir}/libs/micronaut-worker/src/test/resources/application-scheduler.yml[]
 ----
 
-TIP: You can let your jobs executed using virtual threads by using `virtual` executor.
+You can use virtual thread factory with all the implicit executor services by setting the `worker.virtual-threads-compatible` property to `true`. Implicit executor services are created for every job that does not customize its own `scheudler` configuration property.
+
+[source,yaml]
+.Enabling Virtual Threads for Implicit Executors
+----
+include::{root-dir}/libs/micronaut-worker/src/test/resources/application-virtual-threads.yml[]
+----
 
 === Job Configuration
 

libs/micronaut-worker/src/main/java/com/agorapulse/worker/WorkerConfiguration.java

@@ -41,7 +41,7 @@ public String getScheduler() {
         }
 
         @Override
-        public boolean isVirtualThreadCompatible() {
+        public boolean isVirtualThreadsCompatible() {
             return DEFAULT_VIRTUAL_THREAD_COMPATIBLE;
         }
 
@@ -56,6 +56,6 @@ public boolean isVirtualThreadCompatible() {
 
     String getScheduler();
 
-    boolean isVirtualThreadCompatible();
+    boolean isVirtualThreadsCompatible();
 
 }

libs/micronaut-worker/src/main/java/com/agorapulse/worker/configuration/DefaultWorkerConfiguration.java

@@ -25,6 +25,7 @@
 public class DefaultWorkerConfiguration implements WorkerConfiguration {
 
     private boolean enabled;
+    private boolean virtualThreadsCompatible = WorkerConfiguration.DEFAULT_VIRTUAL_THREAD_COMPATIBLE;
     private String queueType;
     private String scheduler = WorkerConfiguration.DEFAULT_SCHEDULER;
 
@@ -62,4 +63,13 @@ public void setScheduler(String scheduler) {
         this.scheduler = scheduler;
     }
 
+    @Override
+    public boolean isVirtualThreadsCompatible() {
+        return virtualThreadsCompatible;
+    }
+
+    public void setVirtualThreadsCompatible(boolean virtualThreadsCompatible) {
+        this.virtualThreadsCompatible = virtualThreadsCompatible;
+    }
+
 }

libs/micronaut-worker/src/main/java/com/agorapulse/worker/executor/DefaultExecutorServiceProvider.java

@@ -19,6 +19,7 @@
 
 import com.agorapulse.worker.Job;
 import com.agorapulse.worker.JobConfiguration;
+import com.agorapulse.worker.WorkerConfiguration;
 import io.micronaut.context.BeanContext;
 import io.micronaut.context.Qualifier;
 import io.micronaut.inject.qualifiers.Qualifiers;
@@ -41,9 +42,11 @@ public class DefaultExecutorServiceProvider implements ExecutorServiceProvider,
     private final Map<String, ExecutorService> createdExecutors = new ConcurrentHashMap<>();
 
     private final BeanContext beanContext;
+    private final WorkerConfiguration workerConfiguration;
 
-    public DefaultExecutorServiceProvider(BeanContext beanContext) {
+    public DefaultExecutorServiceProvider(BeanContext beanContext, WorkerConfiguration workerConfiguration) {
         this.beanContext = beanContext;
+        this.workerConfiguration = workerConfiguration;
     }
 
     @Override
@@ -55,7 +58,7 @@ public void close() {
 
     @Override
     public ExecutorService getExecutorService(Job job) {
-        return getExecutor(ExecutorServiceProvider.getSchedulerName(job.getConfiguration()), job.getConfiguration().getFork(), job.getConfiguration().isVirtualThreadsCompatible());
+        return getExecutor(ExecutorServiceProvider.getSchedulerName(job.getConfiguration()), job.getConfiguration().getFork(), workerConfiguration.isVirtualThreadsCompatible() || job.getConfiguration().isVirtualThreadsCompatible());
     }
 
     @Override
@@ -73,7 +76,7 @@ public TaskScheduler getTaskScheduler(Job job) {
         }
 
         return optionalTaskScheduler.orElseGet(() -> {
-            ExecutorService executor = getExecutor(schedulerName, configuration.getFork(), configuration.isVirtualThreadsCompatible());
+            ExecutorService executor = getExecutor(schedulerName, configuration.getFork(), workerConfiguration.isVirtualThreadsCompatible() || configuration.isVirtualThreadsCompatible());
             ScheduledExecutorTaskScheduler scheduler = new ScheduledExecutorTaskScheduler(executor);
             beanContext.registerSingleton(TaskScheduler.class, scheduler, Qualifiers.byName(schedulerName));
             return scheduler;

libs/micronaut-worker/src/test/resources/application-scheduler.yml

@@ -0,0 +1,2 @@
+worker:
+  scheduler: io

libs/micronaut-worker/src/test/resources/application-virtual-threads.yml

@@ -0,0 +1,2 @@
+worker:
+  virtual-threads-compatible: true