executorservice

0热度

2回答

如何在不等待输出的情况下继续CompletableFuture

我遇到了需要用CompletableFuture实现递归的情况。无论何时CompletableFuture s返回任何结果，我都想致电recursionFuture(ex)，但我不确定该如何实现该结果。在当前情况下，只有当future1和future2返回输出，然后检查条件时才调用recursionFuture(ex)。任何帮助，将不胜感激。 public static void recursio

java multithreading threadpool executorservice completable-future 2016-09-24

---

1热度

1回答

什么是最有效的并行实施方式？

考虑50,000个对象的集合。 每个对象通过其doWork（）方法每次迭代产生10次双打。 有一个连续的while循环遍历50,000个对象中的每一个，并调用doWork（）。 之后，创建的10个双打中的每一个都必须通过调用每个对象的process（）来处理。 while循环内的最后一步必须对每次迭代中产生的双精度进行求和，然后记录输出。 设计是否取决于完成doWork（）和process（）所花

java concurrency parallel-processing executorservice fork-join 2016-09-28

---

0热度

1回答

ExecutorService提交vs执行

我是否理解submit和execute之间的区别就像是async和sync调用？在第二种情况下，调用者将被停止直到runnable完成？ public static ExecutorService serialQueue = Executors.newFixedThreadPool(1); 我使用ExecutorService作为串行队列，一次只能运行一个任务。

android executorservice 2016-10-05

---

0热度

1回答

集合中的FutureTask如何在内部工作？

我想了解FutureTask在Collections的工作情况。根据我的理解，我可以使用ExecutorService创建一个线程池。稍后，您可以将Runnable或Callable换成FutureTask并执行它。之后，您可以使用Future对象来检查获取结果或检查任务是否正在运行。但是这在内部是如何做到的？ 我想了解的是当你传递Callable接口时发生在场景后面的事情。我有几个问题是 是否F

java multithreading collections executorservice concurrent.futures 2016-10-15

---

4热度

1回答

如何覆盖executorService关闭方法

我正在创建自己的线程池和将来可以执行可并行调用接口的对象。 Executor提供关闭方法来停止所有工作线程运行。如果我像下面一样创建一个线程池，我应该如何在所有线程完成执行后实现shutdown方法来停止？ 我的自定义线程池看起来像this class MyThreadPool implements java.util.concurrent.Executor { private fin

java multithreading threadpool executorservice shutdown 2016-10-15

---

1热度

1回答

线程排队时没有更新共享列表

我有一个代码，它有两个执行程序，executorShops和executorSections，但第一个并不重要。 我创建了与部分一样多的任务（本例中为三个），但是，只有两个部分同时执行。 每个任务都会更新一个共享列表，但问题只是前两个线程正确更新它。已经排队的第三个线程不会更新它。 下面是其中任务是创建的代码： Runnable task =() -> { LOG.info("Llama

java multithreading executorservice 2016-10-17

---

2热度

1回答

如何测试创建单独线程的方法？

这是第一次，我正在尝试为多线程java程序编写JUnit。 我有一个方法，看起来像下面，你能建议我怎么可以写的JUnit的呢？或者指出任何这样的类似例子？非常感谢您提前... !! public void myMethod(Input input) { if (!this.isStreamingPaused()) { ExecutorService publisherThre

java multithreading junit junit4 executorservice 2016-10-22

---

0热度

2回答

ExecutorService和OutOfMemoryError：无法使用执行程序创建新的本机线程

我有一个基于JSP的（Java）Web应用程序。在这个应用程序中，我可以通过执行外部命令，向机器（PC）询问他们的状态和基于他们IP的实际操作系统。 为了加速请求，我想用线程同时询问更多的机器，即ExecutorService。 相应视图的preRenderView侦听器设置为此方法，我收集所有必须显示的数据。在这里，我初始化执行，这被声明为私有静态类字段（private static Execu

java multithreading out-of-memory executorservice 2016-10-24

---

0热度

1回答

如何分配任务CompletableFuture因此多数民众赞成一旦拿起，它不应该再度回升

我有几个任务这样的： public static String task1() public static String task2() public static String task3() public static String task4() public static String task5() public

java multithreading threadpool executorservice completable-future 2016-09-18

---

3热度

1回答

ExecutorService中选中分配

我学习的ExecutorService和可调用，但是从intelij说我做这一行的选中分配得到一个警告： Future<OrderWorker<OfferType>> future = executorService.submit(new OrderWorker<OfferType>(anOfferSet)); 我不明白如何正确地分配。下面的代码： ExecutorService execut

java multithreading generics executorservice 2016-09-18

---