threadpoolexecutor

2热度

1回答

在Spring批处理ThreadPoolTask​​Executor引用不被垃圾收集

我正在使用Spring Batch并使用ThreadPoolTask​​Executor来分叉多个线程。 文件很大，像175 MB，我正在处理大量的字符串对象。 由于此OutOfMemory错误正在抛出。 下面的配置将调用1个线程来处理1个文件（customDBPartitioner正在拾取文件）。 下面是配置： <bean id="threadPoolTaskExecutor" class="o

java multithreading out-of-memory spring-batch threadpoolexecutor 2017-06-01

---

-1热度

1回答

我们只能使用一个阻塞队列或任何其他数据结构的线程池任务队列？

嗨，我是一个与java并发编程的新手。在我们用于定义任务队列时，我在并发编程中看到的所有示例中，人们使用了不同的blockingqueue实现。 为什么只有阻塞队列？有什么优点和缺点？ 为什么没有其他数据结构？

java multithreading concurrency threadpool threadpoolexecutor 2017-06-12

---

2热度

1回答

ThreadPoolExecutor不使用数据

我已经设置了ThreadPoolExecutor并启动线程以使用阻塞队列中的数据。 在启动时（当我调用下面的startThread时），阻塞队列是空的。 我已经设置线程的超时时间非常大，以便它们不会死亡。 阻塞队列在WorkerThreadPoolExecutor的范围之外创建，并且Runnable项目放在它上面。 public class WorkerThreadPoolExecutor ext

java threadpoolexecutor 2017-06-15

---

1热度

1回答

使用单通道与RabbitMQ中的单线程执行程序进行通信是否正确？

我正在尝试使用RabbitMQ-java客户端API与RabbitMQ服务器进行交互。 我从java client api guide阅读： 作为一个经验法则，共享线程之间的通道情况下是要避免的东西。应用程序应该更喜欢使用每个线程的通道，而不是在多个线程之间共享同一个通道 我想使用一个ThreadPoolExecutor与corePoolSize 1并添加Runnable任务来保存消息在Rabbi

java multithreading rabbitmq threadpoolexecutor 2017-06-15

---

0热度

2回答

Java线程 - 等待返回的数据，但不会阻止其他线程

我有7个线程在处理数据和偶尔从另一个线程运行的监听器实例需要数据的ExecutorPool运行。监听器通过套接字向服务器发送请求，并在稍后返回结果时，监听器将数据返回给调用它的工作线程。我想阻塞工作线程，直到返回请求的数据，但我不想阻止侦听器从其他工作线程发出其他请求。我怎么做？

java multithreading threadpoolexecutor 2017-04-26

---

1热度

1回答

什么是ThreadPoolTask​​Executor的Spring默认队列大小？

我使用Spring 4.3.8.RELEASE与Java 7.我想创建一个线程池来执行任务，所以我成立了我的春节contxet <bean id="myThreadFactory" class="org.springframework.scheduling.concurrent.CustomizableThreadFactory"> <constructor-arg value="myt

spring multithreading queue threadpool threadpoolexecutor 2017-06-19

---

0热度

4回答

如何实现阻塞线程池执行器？

我们有一个大的文本文件，其中每行需要密集的process。设计方案是使用class来读取文件，并通过thread pool将每行的处理委托给thread。一旦池中没有空闲线程来执行处理，应该阻止读取文件类读取下一行。所以我需要一个blocking thread pool 在当前实现ThreadPoolExecutor.submit()和ThreadPoolExecutor.execute()方法抛

java multithreading threadpoolexecutor 2017-06-20

---

3热度

1回答

运行akka项目时java.library.path异常no leveldbjni64-1.8

我试图从主类启动一个现有的项目。但在下面得到例外。 java.lang.UnsatisfiedLinkError: Could not load library. Reasons: [no leveldbjni64-1.8 in java.library.path, no leveldbjni-1.8 in java.library.path, no leveldbjni in java.libr

akka persistence threadpoolexecutor leveldb 2017-05-03

---

3热度

2回答

空闲线程在Java执行程序中执行CPU执行时间吗？

当我有这个代码的应用程序： Executors.newFixedThreadPool(4); ，但我从来没有使用此线程池。空闲线程会消耗CPU时间吗？如果是这样 - 为什么？

java multithreading threadpoolexecutor cpu-time 2017-05-05

---

1热度

2回答

Java ThreadPoolExecutor未创建新线程？

我想使用不同的线程从共享的整数列表中删除值。为此，我决定使用ThreadPoolExecutor服务。 首先，我创建了一个BlockingQueue来存储100万个值。 BlockingQueue q = new LinkedBlockingQueue<Integer>(); for (int i=0;i<100000;i++) q.add(i); 其次，我的Thread

java threadpoolexecutor 2017-05-09

---