无法停止使用 ExecutorService 启动的任务
抱歉,我必须打开一个新线程来描述这个问题。 今天早上我问了这个问题,已经有一些回复了,但是我的问题还是没有解决。 这次我将附上一些可运行的代码…
如何立即停止使用 ExecutorService 启动的任务?
我尝试了许多不同的方法来立即停止使用 ExecutorService 启动的任务,但没有成功。 Future future = executorService.submit(new Callable( public Vo…
用java编写一个简单的基准测试工具
我想用 java 编写一个简单的基准测试工具,它将启动 x 个线程并总共点击 y 次 url。 它的实际任务部分将向 URL 发出 Web 请求,并发布 XML 文件。 所…
Java:同步 ExecutorService 有必要吗?
我有一个包含可以在线程之间共享的 ExecutorService 的类: class MyExecutor { ExecutorService e = Executors.newSingleThreadExecutor(); .... ...…
我是否需要对不返回我关心的值的 Future 执行 future.get() ?
我的 Java 应用程序使用 java.util.concurrent.Executors.newCachedThreadPool() 来启动许多执行不同类型工作的不同线程。 一些线程返回一个值。对于…
Java ExecutorService invokeAll() 中断
我有一个宽度为 10 的固定线程池 ExecutorService,以及一个包含 100 个 Callable 的列表,每个线程池等待 20 秒并记录它们的中断。 我在一个单独的线…
FixThreadPool 和 ExecutorCompletionService 出现 OutOfMemory 错误
我正在开发应用程序,应该从数据库获取用户列表并从目录(ldap 或 AD)更新详细信息。我在多核机器上执行此过程,因此我创建了此应用程序(代码如下)…
抛出 ExecutionException 但没有原因
我有一个 future 任务,它通过套接字对服务器执行一些 I/O 操作。当我使用任务的 get() 方法检索结果时,我收到 ExecutionException,但没有任何原因…
ExecutorService JProgressBar
这可能是一个简单的问题,但我尝试了很多不同的事情,无论我尝试什么,我都无法让它发挥作用。 基本上我有一个 JProgressBar,我想在处理任务列表时更…
ListenableFutureTask/ExecutorService
我的类路径中有 Guava,并且想要使用 ListenableFuture,但目前我不知道如何提交 ListenableFuture,或者目前只能在不使用的情况下使用它们调用线程中…
确定ExecutorService的关闭时间
我有一个 ExecutorService 来处理一些任务。客户端线程可以调用ExecutorService上的shutdown()。我想在 ExecutorService 完全关闭后运行一些清理代码…
Akka / future——Akka 是否决定它是否“值得”?使用当前线程还是调度程序?
我目前正在考虑使用 Akka(Java API/库)来完成创建多个 Future 并将它们放入 BlockingQueue 的任务。现在,由 Callables 处理的某些任务可能在调用线…