当前位置: 首页 > 知识库问答 >
问题:

spring能提供像作业队列这样的概念吗

施锋
2023-03-14

例如,我有一个25个作业,我想并发执行3个作业,在三个作业中的一个完成后,下一个从队列中提取。

共有1个答案

燕建中
2023-03-14

您可以使用标准Java库中的类来实现这一点--您不需要Spring来实现这一点。使用ExecutorService,例如:

class MyJob implements Runnable {

    private final String message;

    MyJob(String message) {
        this.message = message;
    }

    @Override
    public void run() {
        System.out.println(message);
    }
}

public class Example {

    public static void main(String[] args) {
        // Executor service with 3 threads
        ExecutorService executorService = Executors.newFixedThreadPool(3);

        // Submit jobs to be executed
        executorService.execute(new MyJob("testing"));
        executorService.execute(new MyJob("one"));
        executorService.execute(new MyJob("two"));
        executorService.execute(new MyJob("three"));

        // ...
    }
}
 类似资料:
  • ●团队可以是一个公司、部门、项目小组,是一些人为了某个共同目标而一起编辑和使用 地图的组织,也是亿景智图中的付费主体或是单元。例如,A团队购买了亿景智图的 vip 服务,那么,A团队下面的地图享受 vip 服务,团队成员在该编辑和使用该地图时是 vip 权限,每个亿景智图用户可以同时属于多个不同的团队,但只有参与的付费团队才享有 vip 权限,其他参与的团队仍属试用服务。 [查看原图]

  • 问题内容: 您是否知道/使用任何针对python的分布式作业队列?您可以共享链接或工具吗 问题答案: 如果您使用的是Django,那么除了进行多处理之外,还有Celery项目。

  • 我有一个spring应用程序,它从一个队列(aws sqs)检索消息,向外部供应商呈现和发送请求,获取响应,再次处理它,并将其放回另一个处理过的队列。Spring应用程序没有API,只能通过队列进行通信。我需要确定应用程序的吞吐量(MSG/s)。做这件事最好的方法是什么?我的用例有任何现存的工具吗?

  • 本文向大家介绍12个提高JavaScript技能的概念(小结),包括了12个提高JavaScript技能的概念(小结)的使用技巧和注意事项,需要的朋友参考一下 JavaScript 是一种复杂的语言。如果是你是高级或者初级 JavaScript 开发人员,了解它的基本概念非常重要。本文介绍 JavaScript 至关重要的12个概念,但绝对不是说 JavaScript 开发人员只需要知道这些就可以

  • 问题内容: 我看过许多实现,它们看起来都如此不同,以至于我无法真正提炼出诺言的实质。 如果我不得不猜测,它只是在触发回调时运行的函数。 有人可以在不带链接的几行代码中实现最基本的承诺。 片段1 该函数如何传递才能知道何时运行。 也就是说,它如何传递回ajax完成时触发的回调代码。 片段2 这两个摘要有什么关系? 猜测: 问题答案: 有人可以在几行中实现最基本的承诺吗? 这里是: 这两个摘要有什么关

  • 问题内容: 当我看一看lambda表达式时,这本书涉及一个只有一种抽象方法的 功能接口 。我的问题针对该测验问题 我知道最后一个不是,但是我认为第一个和第二个应该是功能接口。但是书上说第二个不是。为什么?它不重写方法吗?因此,即使在第二秒,也不是只有一种抽象方法吗? 问题答案: 一种简单的查找方法是尝试定义一个实现的类。编译器会告诉您需要同时实现和。 您以为可以覆盖,这是可以理解的,但是它们实际上