quarkus和ScheduledExecutorService

Question

Quarkus有一个https://Quarkus.io/guides/scheduler来调度任务。但是，我希望使用scheduledexecutorService。Quarkus允许这样吗？例如，在wildfly中，必须使用ManagedScheduledExecutorService，因为服务器正在管理线程，而不允许用户管理线程。这对Quarkus也有效吗？

Answer 1

这是一个SimpleSheduler类

包:包io.quarkus.scheduler.runtime；

https://github.com/quarkusio/quarkus/blob/main/extensions/scheduler/runtime/src/main/java/io/quarkus/scheduler/runtime/simplescheduler.java

为了开发调度程序扩展，他们使用了ScheduleDExecutorService。

下面是一个使用ScheduledExecutorService的已调度任务，

import javax.enterprise.context.ApplicationScoped;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
@ApplicationScoped
public class ScheduledExecutorRunnable {

  List<String> list =
        new ArrayList<String>();

    public List<String> get() {
        sheduleTask();
        return list;
    }

     void sheduleTask() {

        ScheduledExecutorService ses = Executors.newScheduledThreadPool(1);
        Runnable task2 = () -> list.add("Running task2...");
        task1();
        ses.schedule(task2, 10, TimeUnit.SECONDS);
        task3();
        ses.shutdown();

    }

     void task1() {
        list.add("Running task1...");
    }

     void task3() {
        list.add("Running task3...");
    }

}

演示

import com.knf.dev.Resource.ScheduledExecutorService.ScheduledExecutorRunnable;

import javax.inject.Inject;
import javax.ws.rs.GET;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import javax.ws.rs.core.MediaType;
import java.util.List;

@Path("/verify")
public class EndPoint {

    @Inject
    ScheduledExecutorRunnable scheduledExecutorRunnable;

    @GET
    @Path("/sheduler")
    @Produces(MediaType.APPLICATION_JSON)
    public List<String> sheduler() {
        return scheduledExecutorRunnable.get();
    }
}

10s后到达终点

产出：

[“运行任务1...”、“运行任务3...”、“运行任务2...”、“运行任务1...”、“运行任务3...”]