Java：addScheduledJobAfterDelay() - 我可以强制启动计划作业吗？

Question

我正在开发一款扑克游戏。在投注阶段，我使用 Red5 iSchedulingService 创建一个计划作业，该作业每 8 秒运行一次，转发给下一个玩家进行投注。现在，如果用户在 8 秒结束之前下注，我想手动强制启动下一个计划作业。

有没有办法强制预定的作业在需要时立即开始？

Answer 1

您可以使用 执行器。有更干净的实现，但这是一个尝试和一些基本的东西，可以使用 未来 和 可调用。

// wherever you set up the betting stage
ScheduledExecutorService bettingExecutor = 
    Executors.newSingleThreadScheduledExecutor();

ScheduledFuture<?> future = bettingExecutor.schedule(new BettingStage(), 8,
    TimeUnit.SECONDS);

//...

// in the same class (or elsewhere as a default/protected/public class)
private class BettingStage implements Callable<ScheduledFuture<?>> () {
    public ScheduledFuture<?> call() thows ExecutionException {
        ScheduledFuture<?> future = bettingExecutor.schedule(new BettingStage(), 8, 
            TimeUnit.SECONDS);
        // betting code here
        boolean canceled = future.cancel(false); // cancels the task if not running yet
        if(canceled) {
             // run immediately
             future = bettingExecutor.schedule(new BettingStage(), 
                0, TimeUnit.SECONDS)
        }
        return future;
    }
}

Answer 2

我在这个线程中开始的具体问题的答案：

我不能强制启动计划作业，但我可以做的是删除计划作业并延迟 0 秒启动新作业。

addScheduledJobAfterDelay() 返回一个表示作业 ID 的字符串。我可以用它来删除预定的作业。问题是没有办法知道我是否中断了预定的工作。执行者确实提供了这些信息。这就是为什么在这种特定情况下执行器是比使用 red5 调度服务更好的选择。

如何删除计划作业 (red5)：

ISchedulingService scheduler = (ISchedulingService) getScope().getContext().getBean(ISchedulingService.BEAN_NAME);
     scheduler.removeScheduledJob("ScheduleJobString");

字符串 ScheduleJobString 应替换为您在创建作业时收到的字符串：

String scheduleJobString = scheduler.addScheduledOnceJob(DelayInSeconds*1000,new MyJob());