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 处理的某些任务可能在调用线…
Executors.newSingleThreadExecutor() 的退出策略是什么
我对java并发很陌生,所以这可能是一个已经回答过很多次的问题,或者太明显了,我可能遗漏了一些东西。 我像这样作为任务运行: Executors.newSingleT…
Java正确使用ExecutorService、CompletionService、BlockingQueue和Observer?
所以,我对多线程还很陌生,并且最近在我的所有程序中都使用了这个想法。在我开始更多地使用它之前,我真的想确保它是使用 Executor、CompletionServi…
ExecutorService 多线程性能慢
我正在尝试执行一个简单的计算(它调用 Math.random() 10000000 次)。令人惊讶的是,以简单的方法运行它比使用 ExecutorService 执行得快得多。 我读…
调度在 ExecutorService 上的守护线程;解释为什么这是不好的形式
我对使用 ExectuorService 调度的线程有序关闭的想法感到满意;也就是说,调用 shutdown 或 shutdownNow 将导致池中创建的线程正常退出。如果它们响应…