玩！ - 动态结束作业

发布于 2024-12-07 11:41:02 字数 512 浏览 1 评论 0原文

因此，假设我从控制器异步启动一项作业，然后渲染一些模板。

MyJob job = new MyJob();
job.doJob();

render();

MyJob 看起来像：

import play.jobs.*;

public class MyJob extends Job {

    public void doJob() {
        // execute some application logic here until I say to quit via a controller method
    }

}

从 UI 中，我执行一些操作，然后触发对控制器中另一个路由的请求，这将结束作业。我不想在客户端处理复杂、连续的 DAO 操作，那么解决这个问题的最佳方法是什么？我有一个 EC2 弹性缓存设置，因此主要问题是为作业分配 ID。

 job.endJob(id); ?

原文

So, let's say I start a job from a controller asynchronously and then render some template.

MyJob job = new MyJob();
job.doJob();

render();

MyJob looks like:

import play.jobs.*;

public class MyJob extends Job {

    public void doJob() {
        // execute some application logic here until I say to quit via a controller method
    }

}

From the UI, I do some actions, and I trigger a request to another route in the controller which would end the job. I don't want to have complicated, continuous DAO actions handled on the client side, so what is the best way to go about this? I have an EC2 elastic cache setup, so the main problem is assigning an ID to a job.

 job.endJob(id); ?

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

笑咖 2024-12-14 11:41:02

如果您查看 JobsPlugin 类 -它使用ScheduledThreadPoolExecutor执行器来维护作业列表。

这个类有一个 remove方法，你可以尝试使用。

回复收藏 0 原文

舂唻埖巳落 2024-12-14 11:41:02

我不知道有什么方法可以轻松停止作业。由于 Play 是无状态的，因此最好的选择可能是在数据库中添加一些标志，作业可以检查该标志以决定停止，但对我来说这看起来不是一个很好的解决方案。

您是否在 Play 中检查过Continuations？我相信它们可能更适合您的场景。

回复收藏 0 原文

夏九 2024-12-14 11:41:02

private static ScheduledFuture<?> future;
private static final TestJob testJob = new TestJob();

future = JobsPlugin.executor.scheduleWithFixedDelay(testJob, 1, 1, TimeUnit.SECONDS);

future.cancel(true);

future = JobsPlugin.executor.scheduleWithFixedDelay(testJob, 5, 5, TimeUnit.SECONDS);

private static ScheduledFuture<?> future;
private static final TestJob testJob = new TestJob();

future = JobsPlugin.executor.scheduleWithFixedDelay(testJob, 1, 1, TimeUnit.SECONDS);

future.cancel(true);

future = JobsPlugin.executor.scheduleWithFixedDelay(testJob, 5, 5, TimeUnit.SECONDS);

回复收藏 0 原文

~没有更多了~