在 Java 中使用线程进行集群

Question

我有一份 Java 工作需要很长时间。所以我想把这个工作分成线程并运行它们。线程完成其工作后，返回到我的服务，并且服务为它们提供新的工作。 ThreadGroup 适合这个还是有其他推荐？

Answer 1

首先，如果满足以下条件，则需要线程：

a) 您有一台多处理器计算机

，或者 b) 您有一个处理器，但您的作业是 IO 密集型（而不是 CPU 密集型）

，否则，使用线程时您将一无所获。

您需要的是 ThreadPool

Answer 2

查看 ExecutorCompletionService - 它正是这样做的。

示例：[摘自 Java 6 API JavaDocs]

 void solve(Executor e, Collection<Callable<Result>> solvers)
     throws InterruptedException, ExecutionException {
       CompletionService<Result> ecs
           = new ExecutorCompletionService<Result>(e);
       for (Callable<Result> s : solvers)
           ecs.submit(s);
       int n = solvers.size();
       for (int i = 0; i < n; ++i) {
           Result r = ecs.take().get();
           if (r != null)
               use(r);
       }
   }

Answer 3

不确定您的项目当前处于什么开发状态，因为您的问题陈述非常有限，但您可能需要考虑查看 JDK7 中的 fork-join 项目： http://www.ibm.com/developerworks/java/library/j-jtp11137.html

有收获很多通过查看它来学习，并且由于它都是开源的，因此您已经可以下载代码作为补丁并尝试使用它。

（可能不适用于您现在必须实现的任何内容，但如果您打算在未来一段时间内开发/维护您的应用程序，仍然值得一看）

Answer 4

看一下 java .util.concurrent 包。

有一个教程，您应该在这里找到您需要了解的所有内容：

http:// /java.sun.com/docs/books/tutorial/essential/concurrency/

重点关注 高级并发对象 特别是。

Answer 5

ThreadGroup 通常对应用程序代码没有多大用处。它对容器代码也没有多大用处。 Java PlugIn 使用ThreadGroup 来区分线程属于哪个applet。

java.util.concurrent，特别是ExecutorService，提供了处理线程和并发的便捷实用程序。

对于计算密集型细粒度任务，JDK7 中的 fork-join 框架将很有用。

在开始编写这段困难的代码之前，您可能需要考虑它是否值得。您可以进行其他不需要大规模线程使用的优化吗？您正在尝试处理 I/O 延迟吗？如果它是 CPU 密集型的，那么使用比硬件多得多的线程并没有多大意义。