为什么 ScheduledExecutorService 没有按预期工作？
我正在创建一个 10 个线程的池 每个线程运行3秒 我将每个任务的启动周期设置为0.5秒 问题是，如果池由10个线程组成，启动周期为0.5秒，为什么从第一个…
在Java中，如何测试与公共方法中包装的执行器服务并行运行的私有代码
我有一个现有的非并行代码，我们最近通过使用执行器服务使其并发。在我们的场景中，添加并发性可确保限制发送到另一个 API 的请求数量。因此，我们正…
ExecutorService 提交在 Future get 上失败
我有一个查询，我想同时运行任意多次，但现在我运行了 5 次。当我调用 Future.get() 方法读取 ResultSet 时，总是出现错误。当我只运行一个查询时，相…
java并发包中是否有任何执行器可以保证所有任务都按照提交的顺序完成？
用于演示标题中的想法的代码示例： executor.submit(runnable1); executor.submit(runnable2); 我需要确保 runnable1 将在 runnable2 启动之前完成，…
我应该在 Future 上调用 cancel(true) 吗？或者我自己的 FutureTask
我有一个自定义类 MyFutureTask extends FutureTask ，我在该类的 done() 方法上执行了一些代码。 我使用 ExecutorService，将其称为 submit(new MyFu…
ExecutorService 仅运行最近添加的 Callable
我有一个单线程执行器服务，用于通过网络获取一些数据。 当用户在搜索框中输入内容时，我正在对可能的网络任务进行排队。我想要的是取消所有以前的请…
如何从 Callable 返回临时结果？
我使用 ExecutorService 执行了 Callable 对象。 如何从此可调用返回临时结果？ 我知道 Swing 有 javax.swing.SwingWorker#publish(results) 但我不使…
无法停止在 ScheduledExecutorService.schedule 中传递自身的 Runnable
我有一个从 Runnable 实现的轮询器。轮询器将自身传递给 ScheduledExecutorService。由于我根据任务需要不同的延迟时间，因此我使用“schedule”而不…
Grails 执行器 - 无法异步使用 OauthService
我安装了 grails 执行器插件，这样我就可以运行一些需要一段时间才能执行的后台任务。该任务要求我使用 OauthService 调用 LinkedIn API。问题是我似…
ExecutorService 与异步注释
我有一个 EJB 列表，每个 EJB 可能运行超过 1 分钟。我想异步循环运行它们，然后在 10 秒超时后使用 Future 输出检查结果。 据我了解，方法上的 Execu…
运行 ScheduledThreadPoolExecutor 的两个实例
我有许多异步任务要并行运行。所有任务都可以分为两种类型，我们称之为 A 型（耗时）和 B 型（执行速度更快）。 使用具有x池大小的单个ScheduledThrea…
如何关闭等待的服务器？
我创建了一个小型（单线程）服务器并将“工作”代码放入 Runnable 中。然后使用 Javas Executor Framework 在后台线程中执行此可运行程序： ExecutorS…
