threadpoolexecutor

0热度

1回答

我有一个应用程序运行通过多个数据库，并为每个数据库运行所有表上的select查询并将其转储到hadoop。我的设计是一次创建一个数据源连接，并使用获取的连接池在多个线程中运行选择查询。完成此数据源后，关闭连接并创建一个新连接。这里是异步代码 @Component public class MySampleService { private final static Logger

2热度

1回答

阿卡均衡池中有可变大小的线程池执行人

这里是我的使用情况：我想创建一个大小为x的平衡池路由器（x是实例的数量/该在确定routees运行时），每个路由都有自己的专用线程。每个路线预计将执行阻止操作。 Akka文档解释说您不能更改平衡池的调度程序。这就消除了使用固定调度程序的选项（它将完成我所需要的任务，每个routee的大小为1的线程池）。从Akka documentation：的BalancingPool自动使用其route

2热度

2回答

同步任务生产者/消费者使用的ThreadPoolExecutor

我试图找到一种方法在下列情况下使用ThreadPoolExecutor：我有一个单独的线程生产和线程池提交任务一任务提交是同步的，并且将会阻塞，直到在任何给定时间任务可以由任务启动，只有固定数量的任务可以并行执行。无限数量的同时运行的任务可能会导致内存耗尽。在提交任务之前，生产者线程始终检查自第一个提交的任务以来还没有超过一些最大构建时间。如果超过，则线程关闭，但当前在线程池上运行的任何任务

4热度

3回答

的ThreadPoolExecutor：获取正在执行

我使用ThreadPoolExecutor执行在后台多长时间运行的任务的具体Runnable接口的ThreadPoolExecutor池大小是4所以正在增加超过4任务时，他们都推到队列中，并且当一个4个任务完成后，一个任务从队列中移出执行。我想知道有什么方法可以访问Runnable当前正在执行的对象，而不是队列，即前4个任务。目标：我想要在任何给定点上获得当前任务的状态，在mThreadPoo

0热度

1回答

蟒蛇多线程，我怎么能在一次

运行多个操作我试图SFTP发布到远程机器与我的功能 def copyToServer(hostname, username, password, destPath, localPath): transport = paramiko.Transport((hostname, 22)) transport.connect(username=username, password=p

1热度

2回答

如何知道哪个特定的runnable在我的threadPoolExecutor中死亡？

我正在使用newFixedThreadPool()线程固定量，需要能够知道什么时候可运行的一个已经死了，知道哪些具体运行的是死了一个。对此的一个解决方案是将Runnables作为Thread对象包装并调用isAlive()。线程运行，因为他们应该有，但因为aThread.start()永远不会被执行者调用总是返回false这是没有用的。我认为在run()函数的开始处使Runnables触发一

0热度

1回答

Java - 根据请求关闭并发线程

我试图构建一个程序，试图解密使用AES加密为学校项目加密的文件。我有一个约100,000个英语单词的列表，并且希望在程序中实现多线程以优化文件中每个单词尝试解密所花费的时间。我有试图阻止字典的休息时被搜查解密成功完成事件的一个问题 - “试图关闭”被打印到控制台，但现在看来，该线程将继续通过工作执行程序停止分配新线程之前的其余字典。 private void startThreads(){

1热度

1回答

为什么ThreadPoolExecutor $ Worker扩展AbstractQueuedSynchronizer

我知道一些关于AbstractQueuedSynchronizer的细节。它是用于创建状态相关类或同步器的框架。但我没有得到在ThreadPoolExecutor的Worker中扩展这个类的要点。 private final class Worker extends AbstractQueuedSynchronizer implements Runnable 所看到下面的东西Worker类

0热度

2回答

Executor服务中的依赖线程 - Java

我正在处理程序中的多个线程。有一些独立的线程，一些线程在开始执行之前依赖于其他线程的完成。目前，如果它所依赖的仍然是运行的线程，然后等待它的完成我在做这个 for (final String inElementId : inElements) { Thread thread = threadsMap.get(inElementId); if ((thread != null

1热度

3回答

Java - 平衡ThreadPoolExecutor公平地给线程并行请求

我开发了一段多线程的代码。此代码在Web应用程序中调用，因此可能由多个线程（请求）并行执行。为了保持这个代码将要创建的线程数量（通过被几个并行请求调用），我使用一个静态共享的ThreadPoolExecutor（Executors.newFixedThreadPool(nbOfThreads)）。所以我确信这段代码永远不会创建超过nbOfThreads的线程。要跟踪给定请求中涉及的任务并等待它们完