抛出 ExecutionException 但没有原因
我有一个 future 任务，它通过套接字对服务器执行一些 I/O 操作。当我使用任务的 get() 方法检索结果时，我收到 ExecutionException，但没有任何原因…
FutureTask 取消()
基本上我有以下代码片段， (let [task (FutureTask. fn) thr (Thread. task)] (.start thr) ;;wait for signal... (.cancel task true) (.stop thr)) …
发生异常时未来任务异步调用挂起
我在我的 java 程序中写了许多异步未来任务调用。下面给出一个示例 FutureTask> x = getConditionFacts(final Member member); FutureTask> x = getRi…
java Callable FutureTask Excecuter：如何监听已完成的任务
我对执行者服务很陌生。喜欢自己做所有事情，但我认为是时候信任这些服务了。 我想通过 executor 提供一个 Runnable。执行器将其包装在 FutureTask 中…
等待 FutureTask 上的 cancel()
我想取消从 ThreadPoolExecutor 获取的 FutureTask，但我想确保线程池上的 Callable 已停止其工作。 如果我调用 FutureTask#cancel(false) 然后调用 g…
Java中的Future和FutureTask有什么区别？
既然使用ExecutorService可以提交一个Callable任务并返回一个Future，为什么需要使用FutureTask 包装 Callable 任务并使用方法 execute？我觉得他们都…
如何确保提交到 ThreadPoolExecutor 然后取消的 FutureTask 的垃圾回收？
我正在向 ThreadPoolExecutor 提交 Callable 对象，它们似乎保留在内存中。 使用 Eclipse 的 MAT 工具查看堆转储，可以看到 Callable 对象被 FutureTa…
要求 FutureTask 在取消之前启动
在我的可调用代码中，我使用信号通知向另一个线程通知多个结束行为。 Callable 对象与 Executor 中的 FutureTasks 一起排队。排队后也可能被取消。 现…
如何在FutureTask中捕获异常
发现在 Java 1.6（以及来自 Eclipse）上的 Executors.newCachedThreadPool() 中运行的 FutureTask 吞咽了 Runnable.run() 中的异常之后方法，我试图想…
FutureTasks 和 CachedThreadPool 如何工作
我目前有执行以下操作的代码： private final static ExecutorService pool = Executors.newCachedThreadPool(); public void foo(){ FutureTask firs…
如何让 FutureTask 在 TimeoutException 之后返回？
在下面的代码中，我按照预期在 100 秒后捕获了 TimeoutException。 此时，我希望代码从 main 退出并且程序终止，但它继续打印到控制台。 如何让任务在…
Java 5：java.util.concurrent.FutureTask - cancel（）和done（）的语义
我目前正在使用 FutureTasks 和 Executors 在多线程环境中寻找一个令人讨厌的错误。 基本思想是让固定数量的线程执行单独的 FutureTasks 来计算要显示…
寻求 Java ScheduledExecutorService 和 FutureTask 的清晰度
我刚刚开始研究 Java 中的 Futures 和 ScheduledExecutorService，我想知道为什么我的 Callable 没有按照我指定的时间表运行。 在此示例代码中，可调…
您可以将 Future/Futuretask 对象与 Spring TaskExecutors 一起使用吗？
是否可以使用Java FutureTask 使用 Spring TaskExecutor 来获取 未来 对象？ 我正在寻找一个实现 Java ExecutorService 接口，特别是submit() 方法。 …
CompletableFuture的写法是否有错误，因为运行效率并没有提升很多
Integer oneTimeCount = 50; List> createListList = Lists.partition(createList, oneTimeCount); List> futures = new ArrayList<>(); for (int i …
- 共 1 页
- 1
