任务的分钟长轮询或单个调度程序 - 通知系统的方法

Question

我有一个要求，我会在一定的时间间隔内计划多个任务。对于每个任务，必须在特定时间间隔推送通知。我有两种方法，要么编写一个调度程序，每隔一分钟轮询一次并相应地推送通知。或者我可以安排为每个任务初始化一个调度程序。使用前一种方法，解决方案非常简单，使用后一种方法，我可以更好地控制调度程序，例如，我可以为每个任务专门设置初始延迟（这是一项要求），然后停止单个任务，恢复等。到目前为止，我正在使用后一种方法。但我想知道在单个应用程序中使用这么多调度程序是否会更好。还是使用 1 分钟轮询的单个调度程序更好？. 平均而言，我一次会处理大约 200 多个任务。或者为此我可以依赖任何其他图书馆吗？

到目前为止，我的代码 Sheduler是一个 ExecutorService

       //Constructor

            public TaskScheduler(String taskName) {

                this.taskName = taskName;

                this.taskResult = new TaskResult();

                this.taskResult.setStartTime(getNewDate());

                scheduledExecutorService = Executors.newScheduledThreadPool(1);

//DB Operation

            }

    // To stop an individual task

                public TaskResult stop() throws InterruptedException {

                    try {

                        System.out.println("Stopping : " + this.taskName);

                        this.taskResult.setTaskName(this.taskName);

                        this.taskResult.setEndTime(new Date());

                        scheduledFuture.cancel(false);

                        scheduledExecutorService.shutdown();

//DB Operation 

                        System.out.println("Stopping : finished - " + this.taskName + " @ "+ new Date());

                    } catch (Exception e) {

                        e.printStackTrace();

                    }

                    return this.taskResult;

                }

        //Portion to add task

            public TaskScheduler schedule(Runnable task, long initialDelay, long frequency) throws Exception{

                this.taskResult.setFrequencyInSeconds(frequency);

                scheduledFuture = scheduledExecutorService.scheduleAtFixedRate(task, initialDelay, frequency, TimeUnit.SECONDS);

                return this;

            }

Answer 1

最好使用单个调度程序，但您不需要为此编写自己的调度程序。您可以使用Executors.newScheduledThreadPool(1)具有一定数量线程的单个实例来安排所有任务。考虑以下代码：class TaskScheduler {    private ScheduledExecutorService scheduledExecutorService;    public TaskScheduler(int threads) {        this.scheduledExecutorService = Executors.newScheduledThreadPool(threads);    }    //Portion to add task    public TaskExecutionContext schedule(String taskName, Runnable task, long initialDelay, long frequency) {        TaskExecutionContext context = new TaskExecutionContext(taskName);        context.getTaskResult().setFrequencyInSeconds(frequency);        ScheduledFuture scheduledFuture = scheduledExecutorService.scheduleAtFixedRate(task, initialDelay, frequency, TimeUnit.SECONDS);        context.setScheduledFuture(scheduledFuture);        return context;    }}class TaskExecutionContext {    private String taskName;    private TaskResult taskResult;    private ScheduledFuture scheduledFuture;    public TaskExecutionContext(String taskName) {        this.taskName = taskName;        this.taskResult = new TaskResult();        this.taskResult.setTaskName(taskName);        this.taskResult.setStartTime(new Date());        //DB Operation on creation    }    public TaskResult stop() {        try {            System.out.println("Stopping : " + this.taskName);            this.taskResult.setTaskName(this.taskName);            this.taskResult.setEndTime(new Date());            scheduledFuture.cancel(false);//DB Operation on stopping            System.out.println("Stopping : finished - " + this.taskName + " @ " + new Date());        } catch (Exception e) {            e.printStackTrace();        }        return this.taskResult;    }    public TaskResult getTaskResult() {        return this.taskResult;    }    public void setScheduledFuture(ScheduledFuture scheduledFuture) {        this.scheduledFuture = scheduledFuture;    }}如果您需要一些关于计划、创建和停止任务的额外操作 - 可能，最好有单独的TaskExecutionContext，它将满足您的所有需求。当您需要安排任务并将其传递给调度程序时，创建一个上下文。