ExecutorService中的线程分组
在ExecutorService中，我如何将处理特定课程id的所有线程分组，然后在一个线程完成该课程id的处理后，关闭该课程id处理中的所有其他线程？
在一个线程完成进程之前，可以处理进程id的线程数不是一个固定的数字。
List l1 = new ArrayList();
l1.add(thread1);
Map t = new Hashmap();
t.add("courseid1":l1)
因此，当thread1处于进程中时，另一个线程来到进程courseid1中，
l1.add(thread2);
然后，一旦thread1看到课程状态是完成的，我将发送成功到列表L1中的所有线程。
共有1个答案
我将使用ParallelStream，一旦有一个任务失败，或者如果您指定要第一个结果，这将停止所有任务。
Optional<Result> res = tasks.parallelStream().map(t -> process(t)).findFirst();
-
问题内容： 使用return by时，如何中断它？ 问题答案： 为此，您需要将任务分配给，而不是调用。当您执行此操作时，将返回一个可用于操纵计划任务的a。特别是，您可以调用关联程序来中断当前正在执行的任务（或者，如果该任务尚未开始运行，则完全跳过执行）。 顺便说一句，由返回的对象实际上是个。
-
假设我有一个Executors静态工厂方法的ExecutorService实例。 如果我从某个线程提交了一个调用，其中RetVal不是线程安全的本地实例化对象，那么当我从同一个线程获得（）它时，我需要担心retvals的完整性吗？人们说局部变量是线程安全的，但我不确定当您返回一个本地实例化的对象并从其他线程接收它时，它是否适用。 下面是我的定制实现，我只是为了测试。您可以忽略EType枚举。
-
问题内容： 假设我有一个利用该框架的应用程序 当我在调试器中运行此应用程序时，将使用以下（默认）名称创建一个线程：。如你所见，这并不是非常有用，而且据我所知，该框架没有提供一种简便的方法来命名已创建的线程或线程池。 那么，如何为线程/线程池提供名称呢？例如，。 问题答案： 你可以提供一个到。工厂将负责创建线程，并将能够为其命名。 引用Javadoc： 创建新线程 使用创建新线程。如果没有另外指定，
-
我从主线程调用了下面的代码，使用ExecutorService池并启动一个线程来处理找到的每个文件。我正在尝试了解当主线程被kill命令终止时ExecutorService的行为。生成的线程会发生什么？一旦完成工作，它们会立即被杀还是终止？ 还有没有更好/更安全的方法来编写下面的代码段，特别是如果我在无限循环中运行这部分，例如等待文件被放到输入目录并分配线程来处理它们？在这种情况下，我应该创建一个
-
我正在用Java 8编写一个命令行应用程序。有一部分涉及一些计算，我相信使用多个线程并行运行可能会带来好处。然而，我在编写多线程应用程序方面没有太多经验，因此我希望您能引导我朝着正确的方向前进，我应该如何设计代码的并行部分。 为了简单起见，让我们假设所讨论的方法接收到一个相对较大的长数组，它应该返回一个只包含素数的集： 现在，我想重构方法，使其由四个线程并行执行，当所有线程都完成时，返回结果。在我
-
我有一些线程的问题。 我的剧本 1-从文本文件将1000多万行加载到数组中 2-创建5个固定线程的执行池 3-然后它正在迭代该列表并将一些线程添加到队列中 现在活动线程永远不会绕过5个固定线程，这很好，但我发现我的处理器进入100%负载，我已经调试了一点，我看到正在调用构造函数，女巫意味着无论我声明5个固定线程，仍将尝试创建10万个对象。 主要问题是：我如何防止这种情况？我只是想让线程在没有空间的
-
我正在尝试运行这个简单的类，并且对于每个cicle，我正在计算java进程线程的数量。 ps huH p pid wc-l。 对于每个cicle，线程数是availableProcessors（）数的增加。 当ExecutorService在其他线程中运行时，garbace收集器似乎不会释放僵尸线程。 如果我创建了一个静态ExecutorService,它就不会发生
-
是什么导致了这个问题，如何解决？