threadpool

1热度

1回答

我刚刚开始了解如何使用BlockingQueue（数组或链接），我想知道排队如何影响资源（CPU，内存等）？整个队列开始成为服务器问题的大小（不是线程数量而是比例更大）？

3热度

1回答

并行线程我有1点的方法，我想在10个不同的并行线程运行在最大任务，都将是独立存在于彼此之间没有相关性，我的问题是，如果我有100个项目来处理，并想在一次处理10那么如何在运行10做一次。我创建了那里我使用Parallel.ForEach但一个示例代码我需要做什么来设置，所以应该在同时运行10个线程，并假设任何正在运行的任务已经完成了，那么它应该自动采取新的，所以所有的10个线程应该的一直忙着工作，

0热度

1回答

Runnable instanceof Future <?>？

我读了一些javadoc和我遇到this example from ThreadPoolExecutor.afterExecute(...) javadocs: class ExtendedExecutor extends ThreadPoolExecutor { // ... protected void afterExecute(Runnable r, Throwable

1热度

2回答

使用外部命令多处理数千个文件

我想从Python为大约8000个文件启动外部命令。每个文件都是独立处理的。唯一的限制是所有文件都被处理后继续执行。我有4个物理核心，每个核心有2个逻辑核心（multiprocessing.cpu_count()返回8）。我的想法是使用四个并行独立进程池，这些进程将在8个内核中的4个内核上运行。这样我的机器在此期间应该可以使用。这是我一直在做的事情： import multiprocessing

0热度

1回答

得到错误FutureTask @ 2c7b84de使用线程池

这里的时候拒绝是我的代码： class Processor implements Runnable { private int id; private Integer interaction; private Set<Integer> subset; private static volatile AtomicBoolean notRemoved = ne

0热度

1回答

为什么命名管道意外地长时间连接到本地管道服务器？

我遇到了命名管道的问题。如果说30个客户端管道都试图同时连接到本地管道服务器，在4核心机器上，则会发生超时或信号量超时。有时候，最长的时间，一个客户端需要一秒钟才能获得连接。再下一秒等等。我认为本地管道访问应该是快速的。为什么30个客户端 - 即使100个客户端需要相同的时间 - 也只需要1000毫秒就能建立一个连接？ using System; using System.Diagnostics

0热度

1回答

QThread线程池

我想用QThread编写线程轮询。 class ThreadPool: public QObject { Q_OBJECT public: ThreadPool(int maxThreads); void addTask(MyTask *task); private: int maxThreads; QMutex mutex; Q

0热度

1回答

带有ThreadPool的Java Web服务器没有响应

我正在创建一个Java Web服务器，它是测验游戏的一部分。出于测试目的，我已经包含了一个计数器。服务器有一个正在处理线程的FixedThreadPool。服务器有一个BufferedReader，它将从数据库和PrintStream中收集数据，我将用它来将输出写入客户端。现在，Printstream的意图是打印出计数器的结果。但是当我运行服务器时什么都没有发生，printStreamn不能按预

0热度

1回答

使用线程从列表中复制文件

我正在处理一个项目，该项目使用四个线程来复制文件。我创建列表并存储要复制的文件的名称。我想使用这4个线程一起工作，但我真的不知道如何使它发生。 public class CopyingFiles implements Runnable { static File source = new File("C:\\test\\1\\"); static File dest = new File

-1热度

1回答

C＃。是否有自定义线程池的.NET类

我一直在试图找到一个简单的自定义线程池一段时间，并找不到一个，所以写了一个快速穷人的线程池。问题：有任何.NET类已经可以做到这一点？（无数次试图找到它之后找不到它，只有博客文章中的自定义实现比这更复杂！）。更好地消耗线程与轮询或启动线程池上的操作时和当任务进来？ <每天1k任务。这将是对红隼运行的AspNetCore网站代码 public class WorkerQueue : IWo