安排在轮询情况下可能超时的可调用对象的最佳方法是什么？

发布于 2024-07-20 05:35:27 字数 133 浏览 7 评论 0原文

我有几个 Callables 查询一些 JMX Bean，因此每个 Callables 都可能会超时。我想每秒轮询一次值。最幼稚的方法是在单独的线程中启动每个线程，但我想最大限度地减少线程数量。我必须采取哪些选择才能以更好的方式做到这一点？

原文

分享到QQ

分享到微博

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

发布评论

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

别把无礼当个性 2024-07-27 05:35:27

我的解释是，您有一堆 Callable 对象，需要以一定的时间间隔进行轮询。如果您使用线程池，问题在于该池将被最慢的成员污染，而较快的成员将挨饿。

听起来您可以控制调度，因此您可以考虑指数退避方法。也就是说，在 Callable X 运行（并且可能超时）后，您需要等待 2 秒而不是 1 秒才重新安排它。如果仍然失败，请转到 4 秒，然后是 8 秒，依此类推。如果您使用 ScheduledThreadPoolExecutor，它提供了一种内置方法来执行此操作，允许您在设定的延迟后安排执行。

如果您设置恒定的超时，此策略将降低您的池被慢速池垄断的可能性。完全摆脱这个问题是非常困难的。每个查询对象使用单独的线程实际上是确保您不会饥饿的唯一方法，正如您所说，这可能非常消耗资源。

另一种策略是将池分为快池和慢池。如果一个对象超时（比如超过 N 次），则将其移至慢速池。这可以让你的快速池保持快速，虽然慢速池会互相妨碍，但至少它们不会堵塞快速池。如果他们在一段时间内有良好的统计数据，你可以将他们再次提升到快池中。

回复收藏 0 原文

岁吢 2024-07-27 05:35:27

一旦您提交一个Callable，您就会收到一个Future - 未来结果的句柄。您可以决定在给定的时间内等待其完成：

Future<String> future = executorService.submit(callable);
try {
  future.get(1, TimeUnit.SECONDS);
} catch ( TimeoutException e ) {
  future.cancel(true);
} catch ...

调用带有超时的 get 可以让您在任务尚未完成时收到异常。这不区分未启动的任务和已启动但未完成的任务。另一方面，cancel 将采用布尔参数 mayStopIfRunning，因此您可以选择仅取消尚未计划的任务。

As soon as you submit a Callable you receive a Future - a handle to the future result. You can decide to wait for its completion for a given amount of time:

Future<String> future = executorService.submit(callable);
try {
  future.get(1, TimeUnit.SECONDS);
} catch ( TimeoutException e ) {
  future.cancel(true);
} catch ...

Calling get with a timeout allows you to receive an exception if the task has not been completed. This does not distinguish between not started tasks and started but not completed. On the other hand cancel will take a boolean parameter mayStopIfRunning so you can choose to e.g. only cancel tasks not yet scheduled.

回复收藏 0 原文