使用池实现并行处理
是一种常见的并发编程技术，它可以利用多个线程或进程来同时执行任务，提高程序的性能和效率。以下是对该问题的完善且全面的答案：
使用池实现并行处理是指通过创建一个线程池或进程池来管理并发执行的任务。线程池和进程池都是一组预先创建好的线程或进程，它们可以在需要的时候被重复利用，避免了频繁创建和销毁线程或进程的开销。通过将任务分配给池中的线程或进程来执行，并通过合理的任务调度机制进行并行处理，从而提高程序的执行效率。
线程池和进程池的实现原理类似，都是将任务分配给池中的空闲线程或进程来执行。当有新的任务到来时，线程池或进程池会自动分配一个空闲的线程或进程来执行任务，并通过任务队列管理待执行的任务。在任务执行完毕后，线程或进程会返回池中等待新的任务到来，以便继续执行。
使用池实现并行处理的优势包括：
- 提高程序性能：通过并行处理多个任务，可以充分利用计算资源，提高程序的执行速度和吞吐量。
- 节省系统资源：使用池可以减少线程或进程的创建和销毁开销，避免资源的频繁分配和释放，从而减少系统资源的消耗。
- 简化编程模型：使用池可以将任务的管理和调度交给池来处理，开发人员只需关注任务的实现逻辑，简化了并发编程的复杂性。
使用池实现并行处理在各类编程语言中都有相应的实现方式和工具库。以下是几种常见的编程语言和相关工具的示例：
- Python：在Python中，可以使用
concurrent.futures模块中的ThreadPoolExecutor和ProcessPoolExecutor类来创建线程池和进程池进行并行处理。相关链接：concurrent.futures - Java：在Java中，可以使用
java.util.concurrent包中的ExecutorService接口和ThreadPoolExecutor类来创建线程池进行并行处理。相关链接：ThreadPoolExecutor - C++：在C++中，可以使用
std::thread和std::async等标准库提供的多线程机制来实现并行处理。此外，也可以使用第三方库如OpenMP、Intel TBB等来进行并行计算。相关链接：std::thread
使用池实现并行处理的应用场景包括：
- 批量处理任务：当有大量的任务需要处理时，可以使用池来并行执行这些任务，提高处理速度。
- 网络请求并发处理：当需要同时发送多个网络请求并处理响应时，可以使用池来并行发送和处理这些请求，减少总体的响应时间。
- 数据库操作并发处理：当需要执行大量的数据库操作时，可以使用池来并行执行这些操作，加快数据处理和查询的速度。
- 多媒体处理：当需要对大量的音视频文件进行处理时，可以使用池来并行处理这些文件，提高处理效率。
腾讯云提供了多个相关产品和服务，可以用于支持使用池实现并行处理的场景：
- 云服务器（Elastic Cloud Server，ECS）：提供了弹性的虚拟服务器，可以根据实际需求灵活调整计算资源，支持并行处理任务。相关链接：云服务器产品介绍
- 云数据库MySQL版（TencentDB for MySQL）：提供了高性能、可扩展的关系型数据库服务，支持并发执行大量的数据库操作。相关链接：云数据库MySQL版产品介绍
- 人工智能平台（AI Platform）：提供了强大的人工智能开发和训练平台，支持并行处理大规模的机器学习和深度学习任务。相关链接：人工智能平台产品介绍
请注意，以上链接仅供参考，具体的产品选择和使用需根据实际需求和情况进行。
相关·内容
我在互联网上看到了很多例子，为了使用streams来做并行的事情，只需像这样调用.parallelStream()方法：
mySet
.parallelStream()
... // do my fancy stuff and collect
但在其他情况下，我看到线程池子处理中使用了并行流，如下所示：
ForkJoinPool.commonPool().submit(() -> {
mySet
.parallelStream()
... // do my fancy stuff and collect
})
调用parallelS
浏览 0提问于2018-08-31得票数 5
回答已采纳
1回答
我收集了一些我想并行处理的元素。当我使用List时，并行性起作用。但是，当我使用Set时，它不会并行运行。
我编写了一个显示问题的代码示例：
public static void main(String[] args) {
ParallelTest test = new ParallelTest();
List<Integer> list = Arrays.asList(1,2);
Set<Integer> set = new HashSet<>(list);
ForkJoinPool forkJoinPool = new
浏览 1提问于2015-03-11得票数 26
回答已采纳
1回答
我想确保我正确地实现了一个屏障。现在，amStaticThreaded每次被调用都会启动大量的新线程。在我的main例程中，amStaticThreaded之后的所有事情都只能由一个线程完成，但这部分非常快。有没有比每次让amStaticThreaded启动一组新线程更好的方法
我的代码中有以下设置：
void amStaticThreaded(int nshocks, int nstates,
MatrixXd& valmat, MatrixXd& EV_prev, MatrixXd& fullmat) {
#prag
浏览 2提问于2012-03-02得票数 1
回答已采纳
1回答
我正在尝试插入更新MySQL db中非常大的数据值，而在同一次尝试中，我试图在进程列表中看到正在做什么！
因此，我制作了以下脚本：
我有一个经过修改的db MySQL，负责连接。除非我使用多进程，否则一切都很正常，如果我使用多进程，我在某个时候遇到了一个错误，即“失去了到数据库的连接”。
剧本是这样的：
from mysql import DB
import multiprocessing
def check writing(db):
result = db.execute("show full processlist").fethcall()
for i i
浏览 0提问于2018-05-15得票数 1
我有两个版本的代码，它们可以产生相同的结果，其中我试图只并行化嵌套for循环的内部循环。我没有得到太多的加速，但我并不期望1对1，因为我只尝试并行化内部循环。
我的主要问题是为什么这两个版本有相似的运行时？第二个版本不是只派生线程一次，并且避免了像第一个版本那样在每次迭代时通过i启动新线程的开销吗？
代码的第一个版本在外部循环的每次迭代中启动线程，如下所示：
for(i=0; i<2000000; i++){
sum = 0;
#pragma omp parallel for private(j) reduction(+:sum)
for(j=0; j<1000; j+
浏览 0提问于2016-06-06得票数 11
我试图使用OpenMP为具有以下方案的函数编写并行代码：
1. Begin of data-dependent loop
2. Some computation
3. If the result of 2 equals 0 then
3.1. Begin of data-independent loop
3.2. Some computation
3.3. End of data-independent loop
4. Some computation by a single thread
5. Begin of
浏览 4提问于2015-06-27得票数 1
回答已采纳
1回答
我有一个例子来说明我想做什么
queue = 2
def function():
print 'abcd'
time.sleep(3)
def exec_times(times):
#do something
function()
def exec_queue(queue):
#do something
function()
exec_times(3)
#things need be working while it waiting for the function finish
time.sleep(10)
结果应该是
浏览 1提问于2010-07-19得票数 1
回答已采纳
所以我有一些OpenMP代码：
for(unsigned int it = 0; it < its; ++it)
{
#pragma omp parallel
{
/**
* Run the position integrator, reset the
* acceleration, update the acceleration, update the velocity.
*/
#pragma omp for schedule(dynamic, blockSize)
浏览 1提问于2016-12-16得票数 1
回答已采纳
这可能是个愚蠢的问题。但是，如果我有一个简单的函数，并且我想运行它100次，并且我有12个可用的处理器，那么使用10个处理器运行多处理代码更好还是使用12个呢？
基本上，通过使用12个核心，我会节省一次迭代时间吗？或者它将在第一次运行10次迭代，然后再运行2次和10次，等等？
浏览 6提问于2017-05-19得票数 0
回答已采纳
为什么StandardPBEByteEncryptor要锁定一个对象？ "pool-2-thread-115" - Thread t@169
java.lang.Thread.State: BLOCKED
at org.jasypt.encryption.pbe.StandardPBEByteEncryptor.decrypt(StandardPBEByteEncryptor.java:1035)
- waiting to lock <55a2b29b> (a javax.crypto.Cipher) owned by
浏览 28提问于2020-06-16得票数 0
为了更多地了解node.js中的libuv线程池，我编写了以下node.js程序(Ubuntu14.04上的node版本6.2.0 )。在程序中，我读取了两个大小为10KB的文本文件。成功读取文件后，我正在执行一些计算密集型任务(在回调中)。
var log4js = require('log4js');// For logging output with timestamp
var logger = log4js.getLogger();
var fs=require('fs');
fs.readFile('testFile0.txt',f
浏览 3提问于2016-05-22得票数 1
1回答
我有一个函数，它接收图像列表，并在将OCR应用到图像之后，在列表中生成输出。我有另一个函数，它通过使用多处理来控制这个函数的输入。因此，当我有一个列表(即没有多处理)时，列表的每个图像都需要1s，但是当我将必须并行处理的列表增加到4个时，每个图像都得到了惊人的13s。
为了了解问题的真正所在，我尝试创建一个最小的问题工作示例。这里我有两个函数eat25和eat100，它们打开一个图像name并将其提供给使用API pytesseract的OCR。eat25做了25次，eat100做了100次。
我在这里的目标是在没有多处理的情况下运行eat100，用多处理运行eat25 (有4个进程)。从理论
浏览 1提问于2018-11-25得票数 3
回答已采纳
1回答
我在github中读了一些线程池的代码。
这里有一个很好的，由我修改过的。
#pragma once
#include <vector>
#include <queue>
#include <memory>
#include <thread>
#include <mutex>
#include <condition_variable>
#include <future>
#include <functional>
#include <stdexcept>
class ThreadPoo
浏览 0提问于2021-05-23得票数 0
3回答
以下是我对Java 8的的理解：
创建源的东西
该实现负责提供一个方法，该方法依次返回一个可以并行运行其操作的Stream。
虽然有些人已经有了来使用一个自定义线程池，其中包含了Stream框架的并行执行，但在Java8API中，我始终找不到任何关于默认Java8并行流实现将使用的说法。(，类中的方法，以及我不知道的API中其他可能的并行支持流源)。
我唯一能从搜索结果中看到的奇闻是：
含糊地提到了Stream框架和Fork/Join机器。
叉子/联接机械的设计是为了使这一过程自动化。
几乎直接声明道，Collection接口的默认方法#parallelS
浏览 6提问于2014-07-08得票数 27
回答已采纳
1回答
我有一个Java应用程序，它使用RESTeasy和Hibernate在Wildfly 10上运行。应用程序非常简单，它有实体、DAO和资源：
@Entity
public class MyEntity {
// ...
}
@Stateless
public class MyDAO {
@PersistenceContext
private EntityManager em;
public List<MyEntity> list() {
return this.em.createQuery("select e fro
浏览 6提问于2016-05-31得票数 0
回答已采纳
1回答
我正在构建我的第一个单生产者/单消费者应用程序，在该应用程序中，消费者将项目从队列中取出并存储在MySQL数据库中。
以前，当它是一个单线程应用程序时，我会打开到DB的连接，发送查询，关闭连接，并在每次新信息传入时重复。
通过生产者-使用者设置，处理DB连接的更好方法是什么？在启动使用者循环之前，我应该打开它一次吗？(我看不出这有什么问题，但我相信如果有这样的问题，你们中的一位好朋友会指出的)？还是应该在循环的每一次迭代中打开和关闭DB连接(似乎是浪费时间和资源)？
这个软件运行在大约30台小型linux计算机上，它们都与同一个数据库通信。我不认为30个同时连接是一个问题，但我想听听你的想法。
浏览 0提问于2013-12-17得票数 0
1回答
我有一个api_urls的列表
api_urls = [api_url_1, api_url_2, api_url_3]
对于这些URL中的每一个，我必须遍历分页以获得所有数据：
def get_data(api_url):
next_page = 1
results = []
while next_page is not None:
response = query(api_url)
results.extend(response["data"])
next_page = response["ne
浏览 4提问于2022-01-23得票数 1
2回答
我有10亿条未排序的记录，它们彼此无关，我必须使用Java在每条记录上调用一个函数processRecord。
这样做的简单方法是使用for循环，但这需要很长时间。
我可以想到的另一种方式是使用多线程，但问题是，如何有效地划分记录数据集，以及在多少个线程之间()。
是否有一种有效的方法来处理这个大型数据集？
浏览 0提问于2018-04-08得票数 1
回答已采纳
对不起，如果这个问题看起来是重复的话，但我无法从其他答案中找到一个解决办法。我使用Npgsql访问postgre。我有多个客户同时从DB读取。我有异常-行动正在进行中。我知道背后的原因。我在用
public bool ReadRecord(arguments)
{
....
NpgsqlDataReader reader = cmd.ExecuteReader();
while (reader.Read())
{
...
}
...
}
调用例程
private void GetBundleIdAndIsWat(arguments)
{
...
浏览 0提问于2020-12-29得票数 1
回答已采纳
我使用IgniteCache.loadCache(null, keyClassName, sqlArray)通过运行sqlArray指定的sql查询将RDMS数据加载到缓存中。
看起来，loadCache内部将使用ThreadPool运行sqlArray (每个ThreadPool将在任务中运行)
我的问题是: IgniteCache内部会控制并行吗？我有以下情况：
我的数据源的最大连接设置为200。
sqlArray的长度约为1000，因为我有一个大表：select * from person where id >=0 and i <=20000 ... select *
浏览 3提问于2016-12-20得票数 1
回答已采纳
2回答
我正在运行一些Python程序，我注意到瓶颈在行中，执行以下操作
all(foo(s) for s in l)
我想知道的是--怎样才能把它变成并行计算呢？foo(s)是一种线程安全方法，它检查s并根据某些标准返回真假。foo不改变数据结构。
所以问题是
如何并行测试列表l中的所有元素是否都具有属性foo，当l的一个元素不满足foo时立即退出？
编辑。添加更多上下文。我不知道您在寻找什么样的上下文，但在我的场景中，s是一个图，foo(s)计算一些图的理论不变量(例如平均距离或类似的东西)。
浏览 5提问于2015-04-14得票数 1
回答已采纳
1回答
期货上市最有效的方式
、、、、
我通过一个对象列表调用异步客户端方法。该方法返回未来。
在调用后返回的期货列表中，什么是最好的迭代方式(以便处理那些最先出现的期货)？
注意:异步客户端只返回未来，而不是CompletableFuture。
以下是守则：
List<Future<Object>> listOfFuture = objectsToProcess.parallelStream()
.map((object) -> {
/* calling an async client returning a Future<Object> */ })
.co
浏览 1提问于2017-04-05得票数 8
回答已采纳
我有一个从DataTable运行Parral.Foreach的应用程序。在该并行( 3-10个parallels)中，该类执行update或select语句。我有一个MySQL连接，{get;set;}见下文。
public static MySqlConnection Connection { get; set; }
public static MySqlConnection OpenCon(string ServerAddress,int PortAddress, string UserID, string Password,int ConnectionTimeOut)
{
浏览 0提问于2012-04-03得票数 0
在子进程中，我们将进程分成多个进程进行并行处理，在异步编程中，我们也并行执行多个异步代码。
所以这意味着两者是一样的。请帮助我理解这一点
浏览 0提问于2019-12-16得票数 1
1回答
我一直在研究阿克卡演员模型。我有一个实用程序，1000多个演员将活跃，我必须处理这些演员。我想通过application.conf中定义的配置来控制线程数。
但不是。在我的应用程序中创建的dispatcher线程使我在调优dispatcher配置时无能为力。每次重新启动应用程序时，我都会看到创建了不同数量的dispatcher线程(每次启动应用程序后，我都会通过Thread转储检查这个线程)。
甚至线程计数也不等于我在并行-min中定义的线程数。由于线程计数低，我的应用程序处理得非常慢。检查号码的时候。通过下面的代码在我的机器上运行：
Runtime.getRuntime().availab
浏览 5提问于2020-03-18得票数 0
我在我的Maven项目中使用JUnit 5。
我的junit-platform.properties看起来是这样的：
junit.jupiter.execution.parallel.enabled=true
junit.jupiter.execution.parallel.mode.default=concurrent
在IntelliJ内部或在本地运行Maven时，测试将并行执行。
但是，当在云中Maven Docker容器中运行它们时，它们似乎是按顺序运行的。
这就是它们的名称：
steps:
- name: 'maven:3-jdk-11-slim'
arg
浏览 3提问于2019-10-11得票数 2
回答已采纳
2回答
我想知道在行业实践中，使用多线程方法读取文件的最佳方式是什么。在Java中，我将执行以下类型的操作：
class Reader { Result readFile(File file, Listener callback) }
class Listener { void process(Result r) }
Reader会产生另一个线程来生成一个结果，然后从工作线程中回调Listener。这是一种好的方法吗？这将如何转化为Scala，它可能有其他更好的机制来实现这一点？
浏览 1提问于2012-10-09得票数 7
回答已采纳
我试图了解MaxDegreeOfParallelism在调用Parallel.For时是如何影响并行性的。下面是我正在试验的代码：
static void Main(string[] args)
{
var parallelOptions = new ParallelOptions()
{
MaxDegreeOfParallelism = 1000,
};
Parallel.For(1, 1000, parallelOptions, i =>
{
Console.Wr
浏览 11提问于2015-03-17得票数 5
回答已采纳
Scala 2.9引入了并行集合。对于某些任务来说，它们是一个非常棒的工具。但是，它们如何在内部工作，我是否能够影响行为/配置？
他们使用什么方法来计算最优的线程数量？如果对结果不满意，有没有需要调整的配置参数？
我不仅对实际创建了多少线程感兴趣，还对实际工作是如何在它们之间分配的方式感兴趣。结果是如何收集的，幕后发生了多少神奇的事情。Scala会以某种方式测试一个集合是否足够大，以便从并行处理中受益吗？
浏览 1提问于2011-06-13得票数 28
回答已采纳
我想在TParallel::For生成器中使用C++，但是想知道在这个循环中默认使用了多少个线程？例如，如果我有1000个可以并行执行的迭代，那么它们是通过一次创建1000个线程来执行，还是任何时候的最大线程数都受到逻辑处理器数量的限制？
我的观点是-我不想让TParallel::For一次创建更多的线程，然后CPU支持。那么，如果CPU支持8个线程，那么这些迭代将执行8×8直到执行所有1000次迭代，还是会同时创建1000个线程？
浏览 5提问于2019-11-29得票数 1
回答已采纳
现在，我正在探索并行性(包括多处理和多线程)。期货似乎是一个流行的东西，所以我正在试验是否可以在期货之间创建依赖关系，并在我自己的应用程序中使用它们。 我将使用我编写的以下代码作为示例： from concurrent.futures import ThreadPoolExecutor
import os
def dependent_future():
def thread_fn(x, y):
res = x + y
return res
def thread_fn_with_dep(xy_future, power):
x
浏览 13提问于2021-11-12得票数 0
2回答
多线程应用程序设计
、、、
我目前正在计划一项Windows服务。它将是一个多线程应用程序，它将不断检查和处理数据库记录。我的第一个想法是设置一些最大的可用线程，并为每个进程创建新线程。这是可行的，但是由于我为每一个新进程创建了一个新线程，我担心如果有很多记录要处理，它的开销就会增加。我的问题是，这是一个好的设计还是你会推荐其他的解决方案？
下面是应用程序的基本功能：
检查可用线程数
如果有可用的线程，请检查数据库中是否有要处理的记录。
如果有要处理的记录，请选择其中的前100条
创建一个新过程
为每个记录调用一个web服务，并根据web服务调用结果更新记录(此call+update通常需要大约500 be，因此进程将运
浏览 0提问于2012-07-16得票数 5
我正在尝试使用eventlets来处理大量的数据请求。一次向远程服务器发送100,000个请求，每个请求应生成10k-15k字节的JSON响应。我必须对JSON进行解码，然后执行一些数据转换(一些字段名更改，一些简单的转换，比如English->metric，但有几个转换需要少量的解析)，并将所有100,000个请求以遗留系统期望的几种格式的XML形式发送到后端。我使用的是eventlet示例中的代码，该示例使用imap() "for body in pool.imap(fetch，urls)：...“；稍作修改。到目前为止，eventlet在一个小样本(5K urls)上工作良
浏览 1提问于2015-12-24得票数 1
在ejabberd.yml中，我们有以下一行：
##
## Number of connections to open to the database for each virtual host
##
## odbc_pool_size: 10
我们正在运行启用mysql的ejabberd服务器。MySql服务器连接限制为300。
在进行在线研究(可用的文档非常有限)之后，odbc_pool_size从默认的10增加似乎主要影响(减少)客户端到服务器的连接时间。在一个给定的时间实例中，我们平均有1500名在线用户。
我的问题是: odbc_pool_size变量的确切用途是什么？增大池大小将如
浏览 6提问于2016-08-03得票数 0
回答已采纳
4回答
Java8的线程似乎比系统属性java.util.concurrent.ForkJoinPool.common.parallelism.指定的线程更多。这些单元测试表明，我使用自己的ForkJoinPool使用所需的线程数处理任务，但在使用parallelStream时，线程数量高于预期。
import org.junit.Test;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.TimeUnit;
浏览 6提问于2017-02-28得票数 4
回答已采纳
1回答
我编写了测试REST服务层的黄瓜测试。在应用程序运行和REST端点可用之前，服务层不可用。这是系统级的测试。黄瓜是否公开能够启动测试的REST端点？
我试图实现的流程是：
因此，与其通过黄瓜runnerm启动黄瓜测试，不如通过REST启动测试。
这是黄瓜支持的，还是在REST服务后面公开测试的另一种方法？
浏览 12提问于2022-04-23得票数 0
回答已采纳
1回答
我知道创建太多线程(线程饥饿)对我的应用程序的性能不利，但我不确定这如何转化为异步/等待功能。我了解到Task.Run()使用ThreadPool来执行其代码。我还读到，它并不总是创建一个新线程。
现在我有3点我找不到答案：
我是否需要确保不需要手工处理很多线程，或者是否需要使用.Net-Framework来管理这些线程？
这个代码会导致线程饥饿吗？
Dim ltsk作为ListPerson‘潜在的大对象集合(Task.Run(Sub( pers.CheckPerson))中的每个人的任务列表)，在Next Task.WhenAll(ltsk)中使用自己的Task.Run()长时间运行
浏览 0提问于2013-06-14得票数 0
回答已采纳
我有多个可完成的未来，如：
CompletableFuture<Void> future1 = CompletableFuture.runAsync(() -> xxx);
CompletableFuture<Void> future2 = CompletableFuture.runAsync(() -> xxx);
List<CompletableFuture<Void>> futures = Lists.newArrayList(future1, future2);
当我在下面运行时，这两个未来的任务是否并行运行？异常会抛出一个未
浏览 0提问于2020-02-24得票数 2
回答已采纳
开发人员能告诉叉/连接池创建一定数量的线程吗？如果是的话，那么是否可以保证这么多的线程将由池创建？
浏览 0提问于2018-03-16得票数 0
回答已采纳
我使用reactor-netty请求一组URL。大多数URL属于相同的主机。reactor-netty似乎会为每个URL建立一个全新的TCP连接，即使之前的URL已经建立了到主机的连接。当数百个同时建立的连接建立时，一些服务器会丢弃新连接或开始响应缓慢。 代码示例： Flux.just(...)
.groupBy(link -> {
String host = "";
try {
host = new URL(link).getHost();
} catch (MalformedUR
浏览 140提问于2019-04-29得票数 0
回答已采纳
1回答
我想快速确认一下我的怀疑，RabbitMQ文档的这一部分说：
对使用者的回调是在与连接管理的线程分开的线程上分派的。这意味着使用者可以安全地调用连接或通道上的阻塞方法，例如queueDeclare、txCommit、basicCancel或basicPublish。
每个通道都有自己的调度线程。对于每个频道的一个使用者的最常见的用例，这意味着消费者不支持其他使用者。如果每个频道有多个消费者，请注意，长期运行的使用者可能会延迟向该频道上的其他用户发送回调。
我有各种命令(消息)通过一个单独的入站队列和通道传入，其中附加了一个DefaultConsumer。假设DefaultConsume
浏览 6提问于2014-10-13得票数 2
回答已采纳
2回答
我尝试并行运行100个睡眠任务，使用在自定义ForkJoinPool中提交的Java8(1.8.0_172) stream.parallel()和可用的100+线程。每个任务将睡眠为1s。我预计整个工作将在1秒后完成，因为100次睡眠可以并行完成。不过，我观察到运行时为7s。
@Test
public void testParallelStream() throws Exception {
final int REQUESTS = 100;
ForkJoinPool forkJoinPool = null;
try {
浏览 4提问于2020-01-21得票数 2
回答已采纳
我正在阅读线程，并学习了有关叉/连接API的知识。
我发现，您可以使用commonPool作为管理线程的默认池来运行线程，也可以将线程提交给新创建的ForkJoinPool。
据我所知，两者之间的区别如下：
commonPool是静态创建的主池(其中一些池方法不像通常对其他池那样工作，比如关闭它)，并且主要用于运行应用程序。
默认/公共池中的并行数是核数- 1，其中新创建的池的默认并行数=核数(或系统属性parallelism指定的数量--我忽略了完全限定的系统属性键名)。
根据文档，commonPool对于大多数用途来说都是很好的。
这一切归结为我的问题：
我应该什么时候使用
浏览 0提问于2019-08-28得票数 7
1回答
我尝试了下面的应用程序，其中两个客户端连续发送一条信息，另一个接收他们。但是在这里，messageArrived方法似乎是在一个线程中调用的。因为一旦一个客户端的消息被卡住，其他客户端的消息也不会被接收到。这是我的实现问题，还是这种行为？请指点。下面显示的是我的代码。
import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.Date;
import java.util.Timer;
import java.util.TimerTask;
import org.eclipse.paho.cli
浏览 1提问于2016-01-19得票数 1
回答已采纳
我正在测试可完成的未来。正如所描述的，我认为线程将从公共池中重用，但这个代码片段显示了奇怪的行为
for (int i = 0; i < 10000; i++) {
final int counter = i;
CompletableFuture.supplyAsync(() -> {
System.out.println("Looking up " + counter + " on thread " + Thread.currentThread().getName()
浏览 2提问于2016-08-26得票数 2
回答已采纳
我在Visual (实际上是C++)中编写了一段代码，我意识到，当并行运行一个特定的函数(只是做基本的矩阵乘法)时，在相同条件下不同的运行所需的计算时间是非常不同的。
有以下令人费解的输出: 1/当我第一次运行并行化函数时，omg_get_wtime()给出了比串行版本2/随后调用它的次数高出一个计算时间的方法，它给出了一个大大改进的计算时间。我的问题是:相同的函数最初如何给出不同的时间(也就是说，第一次运行给出的时间与后续运行的时间非常不同.)
#include<iostream>
#include<conio.h>
#include<iomanip>
#
浏览 0提问于2019-05-14得票数 3
4回答
今天，我在我的代码中实现了一个讨厌的黑客，每次对数据库的请求都会打开它自己的连接，因为我无法找到任何方法在与MySQL数据库通信时启用MARS (多个活动记录集)。
在我的C#程序中，我做了很多并行工作，这对于MSSQL 2005和2008 (将;MultipleActiveResultSets=true添加到连接字符串)和SQLite (支持“开箱即用”)之类的数据库没有问题，而且您可以同时从数据库中检索两个数据集。
我知道的一些事情:打开到数据库的连接是很昂贵的，因为我希望将它们保持在最低限度。
有什么建议吗？
浏览 5提问于2010-01-16得票数 2
我正在使用ProcessPoolExecutor执行外部命令，在进程完成后是否有任何方法捕获stderr (类似于子进程)？我捕获executor.submit()未来的结果，但返回0或1。
浏览 4提问于2020-04-02得票数 1
我有一个实体List<Entity> entitiesList的列表。我需要发布和存储每个实体的事件列表。我为实体、所有必需的处理程序、CreateEntityCommand和EntityCreatedEvent提供了一个聚合。目前我所做的是: 1.在循环中创建命令，并通过命令网关从entitiesList为每个实体发送这些命令。
for (Entity entity : entitiesList) {
CreateEntityCommand createEntityCommand = new CreateEntityCommand();
浏览 2提问于2020-05-06得票数 0
5回答
PLINQ到底是什么？
、、、
.NET 4.0框架中添加了PLINQ作为对LINQ的扩展。
那是什么？
它解决了哪些问题？
什么时候合适，什么时候不合适？
浏览 8提问于2009-11-02得票数 41
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
