Apache Camel为使用线程池提供了两种解决方案：
from("seda:stageName?concurrentConsumers=5").process(...)
和
from("direct:stageName").thread(5).process(...)
我想知道，这两种解决办法有什么不同？只是两种书写方式相同还是不一样？用例是什么？
浏览 2提问于2013-10-22得票数 8
回答已采纳
2回答
在我开始使用MariaDB中的线程池之前，my.cnf文件具有以下设置以保持server的稳定。
innodb_additional_mem_pool_size
innodb_buffer_pool_size
innodb_commit_concurrency
innodb_write_io_threads
innodb_read_io_threads
innodb_thread_concurrency
innodb_sort_buffer_size
在我了解到MariaDB免费支持线程池功能之后，我在my.cnf中添加了线程_handling=线程池行，重新启动了SQL server，一切看
浏览 3提问于2016-06-20得票数 0
据我所知，当线程池的线程被阻塞时，CLR必须创建一个新线程。每个线程在内存上大约占用1mb。假设服务器每秒收到10K请求。在这种情况下，不使用异步在内存消耗方面的代价是什么？
浏览 2提问于2020-09-02得票数 1
回答已采纳
1回答
当两个客户机同时调用我的Web方法时，我试图确定会发生什么。为此，我在Python中生成两个异步请求：
rs = (grequests.post(url, data = json), grequests.post(url, data = json))
grequests.map(rs)
请求在我的WebApi中调用一个非异步方法，它正在改变我的资源，这是一个静态类实例。根据我所理解的，API请求不应该同时运行，这就是我想要的，因为我不希望这两个请求相互干扰。但是，如果我在API方法中设置了一个断点，那么这两个请求似乎会同时运行(并行)。这会导致一些不必要的结果，因为这两个请求正在并行地更改相同
浏览 2提问于2016-06-21得票数 1
回答已采纳
我正在写一个程序，这将是多线程。线程都会从共享数据中读取数据，但根本不会写入数据。这种情况下是否存在数据竞争？我不这么认为，因为我没有对共享数据进行任何写入，但我想询问并确保。
浏览 13提问于2017-02-27得票数 1
我是个新手，所以这个问题可能太天真了。我找了一段时间，但没有找到解决方案。
基本上:在WAS控制台中定义一个线程池，将其命名为"ac.work.threadpool“
但是在java代码中，在获取上下文之后，如何查找它。
像这样？：
ctx.lookup("java:ac.work.threadpool")
但不能工作
浏览 2提问于2016-02-13得票数 1
看完这个博客后：
我注意到SideKiq有两个设置，我最初认为它们引用的是相同的东西：
sizeconcurrency 服务器池
并发性在sidekiq.yml中设置，服务器池大小在初始化程序文件夹中的sidekiq.rb文件中设置。
这两种设置有什么不同？
浏览 1提问于2020-10-02得票数 0
我正在尝试使用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
我最近比较了OmniThreadLibrary和.NET中的ThreadPool，我发现Omni在最大线程( 60允许)中受到更多的限制，而.NET在.NET 4.0中可以达到32768。
为什么会有这样的限制？
浏览 3提问于2012-11-19得票数 4
回答已采纳
在boost asio教程中。我不知道
主要功能为boost::thread t(boost::bind(&boost::asio::io_service::run, &io));。
为什么我们要调用两个io_serice.run()
//
// timer.cpp
// ~~~~~~~~~
//
// Copyright (c) 2003-2013 Christopher M. Kohlhoff (chris at kohlhoff dot com)
//
// Distributed under the Boost Software License, Version 1.0
浏览 6提问于2014-03-19得票数 0
回答已采纳
我使用EJB3.0MDB异步地从MQ队列读取消息。此MDB打包为jar，并作为依赖项导入Web项目。
此应用程序部署在Websphere 8.x上，包括激活规范在内的整个配置与本文中显示的配置相似：
我的问题是，如何配置线程池，即要处理消息的线程数量？
我已经找到了一些关于它的IBM文章，但它们都是关于不推荐的ListenerPorts，而不是激活规范。
浏览 4提问于2016-09-21得票数 0
回答已采纳
1回答
如何确保WCF服务使用来自ThreadPool的线程来处理传入的消息？
目前，简单的方法调用(如‘返回null;’)需要大约45秒，而另一个请求正在处理。
下面是我如何注释我的服务类：
[ServiceBehavior(ConcurrencyMode = ConcurrencyMode.Multiple, InstanceContextMode = InstanceContextMode.Single)]
public partial class MyService : IMyService {
...
}
但是，当我在任务管理器中观察进程时，它似乎使用的线程数量是恒定的。即使是在负荷
浏览 6提问于2012-02-17得票数 6
代码：
// Start the query.
final ResultSet r = prepared.executeQuery();
try {
// Returning false from oneRow will stop the process.
boolean goOn = true;
while (r.next() && goOn) {
log.trace("Result: {}", toString(r));
// We did do at least o
浏览 3提问于2013-12-13得票数 0
回答已采纳
有谁知道如何在ParallelExtensionExtras中使用以下类及其用途吗？
IOCompletionPortTaskScheduler.cs
IOTaskScheduler.cs
浏览 1提问于2010-12-31得票数 4
1回答
我有一些线程专用于一个任务(接收和处理请求)，还有一些线程专用于其他任务(长时间运行/CPU密集型任务)。这是一个控制台应用程序。
我希望在所有线程中使用异步/等待，但我了解到异步/等待使用来运行延续，这意味着请求处理可能会因为大量的CPU密集型任务而延迟(是的，这就是为什么我有有限的线程计数来完成这项工作)？
如果我想限制并发性，那么我就不能使用TAP？
如果我想做一些背景工作的应用一生，那么我也不能使用抽头？
我应该用自己的SyncronizationContext来编写一个SyncronizationContext实现吗？
是否有其他方式在某些线程中运行延续？
浏览 1提问于2020-04-13得票数 0
回答已采纳
在使用芹菜执行任务时，我碰到了一个分段错误。在查找了这个问题之后，似乎其他人正在通过使用--pool=threads来解决类似的问题。
当我试图通过--pool=threads时，我得到了ModuleNotFoundError: No module named 'threads'
我不相信这与thread模块是一样的，它会抛出No module named 'thread'的错误。
我如何开始使用线程，以及它是做什么的？
芹菜站点中有关--pool=threads的文档非常稀少。寻找“-池”除了台球以外，不会有任何实质性的回报。
浏览 0提问于2018-09-05得票数 3
回答已采纳
我有一个远程java客户端，它在Wildfly 10上查找JMS连接工厂，一切正常。它只是一个测试程序；一个简单的JMS聊天系统。当我启动多个聊天客户端实例时，有时会出现以下消息： WARN: AMQ212051: Invalid concurrent session usage. Sessions are not supposed to be used by more than one thread concurrently. 后面跟着一条痕迹。 现在我想修复这个警告，因此我需要一个池化连接工厂。但是池化连接工厂不能远程使用(而且据我所知，它也不应该远程使用)。 当我想在本地启动多个JMS
浏览 19提问于2019-09-17得票数 0
1回答
我很难弄清楚Heroku上的并发性是如何工作的，以及如何为Sidekiq设置最优的:concurrency值
这是布景-
Puma Web Server
2 workers
5 threads
Heroku Dynos
8 web dynos
2 "worker" dynos (These will run Sidekiq, not to be confused with Puma Workers)
DB Connections
120 Max Connections Allowed by Postgres
5 Active Record Pool
浏览 0提问于2015-10-01得票数 6
回答已采纳
2回答
我正在从一个网站上抓取内容。我有一个async方法，它递归地访问页面并从页面中抓取内容。在这个递归函数中，我传递一个HashSet和一个List。List收集所有页面的内容，Hashset存储已经访问过的链接，这样我们就不会再访问它们了。这一职能的有关部分如下：
public async Task ScrapeContentRecAsync(string uri, List<Content> allContent, HashSet<string> alreadyVisited) {
...
var pageHtml = await httpClient.GetS
浏览 1提问于2020-06-12得票数 1
回答已采纳
1回答
这在某种程度上与有关。我有一些遗留的EF Core，我需要用许多嵌套的调用来维护，这些调用都不是异步的。我想知道让顶层控制器只使用异步并使用Task.Run()包装服务调用是否正常。
这两个控制器动作之间的区别是什么？在第一种方法中，EF核被同步调用。但是调用被包装在一个Task.Run中，所以我假设它将异步执行。
在第二种情况下，EF核心调用是异步的，但它是否有必要，因为控制器操作是异步的？将在异步内异步.在顶部只需要一个异步调用就能提高性能吗？
案例1
//controller, async call
public async Task<ActionList<
浏览 1提问于2021-06-13得票数 2
回答已采纳
在使用python grpc服务器时，
server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
这是实例化grpc服务器的一般方式。但是在运行时，如果我尝试运行10个以上的客户端实例，它需要服务器流，第11个实例不能工作(我正在运行10个连接到这个服务器并获取流的客户端实例)
即使我将max_workers更改为None，它创建的最大线程也是40个(根据文档，8个核心x 5个)，因此在这种情况下，最多可以同时为40个客户端提供服务。
这是预期的行为吗？
我正在编写我的代码，但尝试使用这里记录的通用grpc python代
浏览 3提问于2019-03-25得票数 1
如果我有这个
static void Main(string[] args)
{
var tasks = new List<Task>();
for (int i = 0; i < 10; i++)
{
tasks.Add(AsyncWithBlockingIO(i));
}
Task.WaitAll(tasks.ToArray());
}
private static async Task AsyncWithBlockingIO(int fileNum)
{
var result = await File.
浏览 1提问于2021-04-15得票数 0
回答已采纳
1回答
我目前在一家公司实习，刚刚开始进入他们的代码。我注意到它们有使用单例类的任务，但是在单例类中有一个将来的对象，用于获取线程转储。
代码是这样的：
singltonclass{
private ExecutorService x= Executors.newFixedThreadPool(1);
getInstance method(){}
methodThatFetchsThreadDumps(){
future is used here;
}
}
在单身人士身上使用未来是个好主意吗？如果使用此单例的任务运行两次且重叠，会发生什么情况？多次使用单例不会导致未来出现意想不到的行为吗？
浏览 4提问于2015-12-21得票数 1
回答已采纳
1回答
当前正在运行后台作业，同时运行其提供的"ActiveRecord::ConnectionTimeoutError".
This is my current database.yml file,
production:
adapter: postgresql
encoding: unicode
database: app_production
username: password
password:
host: app.domain.com
pool: 25
这是我的sidekiq.yml文件，
production:
concurrency
浏览 2提问于2014-02-06得票数 5
回答已采纳
1回答
因此遇到了一些非常类似于此的代码。我只是想知道是否有人能给我解释一下。
看看它是如何使用RX调度器的，然后是Parallel.For，在这个新的TaskFactory.StartNew内部
IDisposable subscription = someObservable.ObserveOn(ThreadPoolScheduler.Instance)
.Subscribe(o =>
{
Parallel.ForEach(xxxs,
x =>
{
浏览 0提问于2020-02-05得票数 0
回答已采纳
1回答
我知道这是一个常见的问题，但我读过无数篇文章，感到很困惑。现在我认为最好不要读))。
那么，ASP.NET是如何工作的(仅针对线程)：
http请求由线程池中的线程处理。
当请求正在处理时，这个线程是繁忙的，因为请求就是在这个线程中处理的。
当请求处理完成后，线程返回到线程池，服务器发送一个响应。
这种描述的行为对吗？
当我在ASP.NET MVC控制器内启动新任务时，会发生什么呢？
public ActionResult Index()
{
var task1 = Task.Factory.StartNew(() => DoSomeHeavyWork());
浏览 5提问于2015-05-22得票数 10
回答已采纳
我们已经将基于Spring批处理的应用程序更新为Spring 4.x和Boot2.0.x的最新版本，并且HikariCP MySQL连接池出现了一些问题。
如果我使用10个连接的默认maxPoolSize，并且使用5个线程，每个线程都启动一个简单的虚拟作业，那么工作正常。(使用SimpleJobLauncher)。所有乔布斯都会立即启动，此后，HikariCP池已经使用了所有返回的连接。
当我做同样的事情时，这个问题就开始了，但是接下来我用了11个线程。然后，我看到应用程序挂起直到连接超时，然后作业被启动。我预计头10份工作将开始，第一份工作完成后，第11份工作.
在工作开始之前，我看到：
H
浏览 0提问于2019-01-21得票数 2
list.parallelStream().forEach(element -> ...);
现在如何限制并行线程的数量？
过去有一种设置系统属性java.util.concurrent.ForkJoinPool.common.parallelism的“黑客”。但这感觉不对，而且它不再起作用了。
您能建议如何将块列表划分为4个部分，然后只并行运行这4个偏差？
浏览 9提问于2022-02-03得票数 1
回答已采纳
当我在默认的执行上下文中同步地做一些计算密集型的事情时，我被告知我正在从Play的渲染线程池中锁定一个线程，这可能会导致线程匮乏。
同时，我被告知
blocking {
doSomethingComputationIntensive
}
将通知Play此线程正在阻塞，这将提示它更有效地分配线程。
这在实践中意味着什么？我的期望是，如果足够多的现有线程被阻塞，它将临时创建新的渲染线程，从而消除了经历单独执行上下文的麻烦。我说错了吗？
浏览 0提问于2017-10-05得票数 0
我正在尝试用Vert.x做一个非常简单的SSH客户端。因为我没有非阻塞的SSH库，所以我必须在rxExecuteBlocking中处理所有的事情。当我在一大块代码中运行所有逻辑时，它工作得很好，如下所示：
public Single<String> exec() {
return vertx.rxExecuteBlocking(f -> {
String result = "";
// connect()
// exec()
// close()
f.complete(result
浏览 11提问于2017-08-08得票数 1
1回答
我在我的linux实例上看到了cassandra进程，它使用了大约38 of的内存，并在它下面显示了大约700个线程。
当通过python或java连接到数据库时？它们是成为主java进程下的线程还是单独的OS进程？
当集群连接产生多个线程时，它们是否也会成为主进程下的线程？如果是，如何区分连接线程和连接生成线程？
为会话线程分配的内存，它是否在非堆内存下分配？
更新- @chris -这是tpstats的输出
[username@hostname ~]$ nodetool tpstats
Pool Name Active
浏览 0提问于2019-02-08得票数 1
回答已采纳
我正在编写一个小程序，用于爬行从RabbitMQ队列接收到的所有urls。我已经用大约6000个urls进行了测试，在处理了其中的一半之后，客户端毫无例外地停止了，所有到rabbitmq服务器的连接都丢失了。我也查过日志了
=WARNING REPORT==== 7-Apr-2016::10:40:50 ===
closing AMQP connection <0.32373.9> (192.168.55.1:55716 -> 192.168.55.100:5672):
connection_closed_abruptly
我正在使用这个连接工厂设置：
ConnectionF
浏览 1提问于2016-04-07得票数 0
回答已采纳
1回答
我一天要上一两次ActiveRecord::ConnectionTimeoutError。有人能帮我计算一下我的应用程序连接到我的DB上的连接数吗？以及优化我的人际关系的建议？
这是我的配置
AWS
Database : Mysql
Version : 5.7.23
Provider : AWS RDS (db.m5.large, vCPU: 2, RAM: 8GB)
3台服务器配置如下
# database.yml
pool: 20
# puma.rb
RAILS_MAX_THREADS : 5
WEB_CONCURRENCY : 2
配置为bellow的1
浏览 2提问于2019-10-17得票数 5
我们已经开发了一个android应用程序，其中包括超过45个服务器调用，其中包括JSON解析。我们已经把我们所有的脚本都放在了谷歌爸爸的服务器上，现在的问题是应用程序在印度运行得很流畅，但在美国我们的客户端设备上却不能很好地工作。他们正在使用T-Mobile服务，并有良好的互联网连接，但应用程序仍然无法及时向服务器发出请求。
此外，这也不是一个与设备相关的问题，因为我们正在三星galaxy Tab2& 3，三星galaxy S，S2，S4和Note3上测试它。但这在我们国家运行良好，但在我们客户的国家美国不行
浏览 2提问于2014-03-28得票数 0
2回答
目前，我们正在开发一个ASMX、AS2.0、IIS 7 web服务，它可以进行一些计算(并返回一个动态生成的文档)，并将采用大约的方式。60秒后再跑。
由于有一台具有多核和大量RAM的大型机器，我希望IIS尽力将到达请求队列中的请求路由到应用程序池线程池的所有可用线程。
但我们的经历却是相反的：
当我们从多个不同的客户端向ASMX服务URL发出请求时，IIS似乎会依次处理这些请求。即请求1到达，正在处理，然后请求2被处理，然后请求3，等等。
问题：
如果有足够的线程可用，是否可以(不更改web服务的C#代码)配置IIS来并行处理请求？
如果是的话:我该怎么做？
没有:有什么解决办法吗？
浏览 5提问于2010-04-20得票数 4
回答已采纳
2回答
同步HTTP处理程序和异步HTTP处理程序之间是否存在性能差异？IHttpHandler vs IHttpAsyncHandler
为什么选择一个而不是另一个呢？
有什么福利待遇？
浏览 0提问于2011-08-18得票数 27
回答已采纳
在我更进一步之前，我想向你保证，我已经做了我的尽职调查，并在网上寻找建议/答案。特别是，我看了以下文章：
在上面的文章中，您将看到user1669664必须“从一种方法发出大约15个不同的webserivce调用”。
我读过matt提供的最好的答案，这个答案基本上需要为每个不同的Webservice调用编写一个可调用的。
问题是..。
我在更大的范围内有一个类似的问题--我需要打大约230个网络服务电话。
如能听取建议，我将不胜感激。我不想写230个可调用的东西！
谢谢。
浏览 1提问于2017-04-12得票数 1
回答已采纳
我正在进行一个项目，在这个项目中，我需要确保每个线程都在特定的范围内工作。例如：
NO_OF_THREADS: 2
NO_OF_TASKS: 10
如果是number of threads is 2和number of tasks is 10，那么每个线程都将执行10 tasks。因此，这意味着两个线程将执行20 tasks。
在实际场景中，这些数字(任务数和线程数)将非常高，因为它们在我的代码中都是可配置的。
在上面的示例中，如果有更多的线程，first thread应该在1 and 10和second thread之间使用id，在11 and 20之间使用id等等。然后，每个线程将建立一个
浏览 0提问于2013-02-25得票数 18
回答已采纳
2回答
作为我项目的一部分，我需要实现一个数据池管理器。我的项目是一个web应用程序，其中许多客户端将请求许多服务。如何获得有关线程池中线程分配到客户端进程的更多信息？谁能提供一些有效实施的指导方针？
浏览 0提问于2011-02-22得票数 0
2回答
使用Apache的多线程
、、、
我的应用程序在多个线程中执行多个查询。
现在，我正在为每个查询创建新的连接，我希望使用池来提高效率。
Apache池可以同时在多个线程中工作，还是会“阻塞”每个线程上的一些同步方法？
如果它阻塞了，我还能用别的东西吗？
更新
在本文中：指出：
因为所有Oracle方法都是同步的，如果两个线程同时尝试使用连接对象，那么一个线程将被迫等待，直到另一个线程完成它的使用。
所以我想DBCP不能处理这个问题了？
我还意识到，在这个场景中，池不会帮助我，因为每个线程都会请求一个连接，并且线程每次都会生成一个新的连接(直到一些线程结束并返回到池的连接)。
浏览 4提问于2012-09-09得票数 10
1回答
什么是池线程？
、、、
当我在Linux上运行pstree -p pid时，它会显示进程的线程树。
许多进程包含称为“池”的线程。其中一些人的生命周期很短。它们看起来像：
tracker-extract(2785)─┬─{dconf worker}(2825)
├─{gdbus}(2826)
├─{gmain}(2827)
├─{pool}(2975)
├─{pool}(2976)
├─{pool}(
浏览 3提问于2015-03-10得票数 1
回答已采纳
我有两颗春豆。一种接收报文的JmsHandler。参阅Message。这将被处理并移交给发送邮件的MailHandler。现在我已经看到，有时消息会在完全相同的时间到达JmsHandler。当进入sendMail方法时，两者中的一个没有得到正确的处理(没有发送邮件)。所以我认为这是一个线程问题。
我有两种可能的方法来处理这个问题：
a)我将sendMail方法设置为synchronized。这意味着下一次执行将被停止，直到第一次被处理。
public class JmsHandler {
@Autowired
private MailHandler mailer;
浏览 0提问于2016-01-21得票数 0
我对ScheduledThreadPoolExecutor很陌生(因为我通常使用简单的Timer，但人们一直建议不要这样做)，我不太明白传递给ScheduledThreadPoolExecutor(int)构造函数的合适整数值是什么。
有人能解释一下吗？
谢谢
浏览 3提问于2013-04-08得票数 16
我们有一个在服务器上运行的web服务，它由在2个服务器上运行的windows服务调用，总共有3个服务器。
偶尔(比如一个月一次/3个月/6个月)，windows服务会记录这个错误消息“线程池中没有足够的空闲线程来完成操作”。
webservice很简单，它接受一个参数并返回一个字符串。
在错误发生后，服务器上的特定windows服务对于后续请求将失败。
不确定这个错误的原因，有什么帮助吗？
浏览 1提问于2011-12-07得票数 1
1回答
我有一个spring，它托管在websphere应用服务器8.5上。它使用数据源连接到数据库，并存储api处理大约10000个并发请求的值。我真正想知道的是，最大连接是否设置为10，连接池是如何连接到数据库的，以及它真正创建了多少会话来实现多达10000个并发请求的负载。
浏览 1提问于2016-09-28得票数 0
回答已采纳
1回答
我有一个场景，我想使用第三方rest apis查询组织的员工信息。这将针对不同的组织完成，我们将获得员工列表，我预计每个组织大约有500到50k用户。
我正处于poc阶段，我想确定处理此问题的最佳方法。一种选择是创建一个java进程，并为每个用户生成单个线程。另一种方法是为每个用户创建一个单独的进程，在该进程中我们编写一些shell脚本来提供每个员工的详细信息。
我的问题是，从维护的角度来看，哪个是更好的解决方案。这可能会发生，由于依赖第三方apis，一些用户可能会有问题。从支持的角度，从调试的角度来看，这可能是一个更好的方法。这可能是一个非常开放的问题。我想知道，以前是否有人遇到过任何情况，
浏览 1提问于2015-06-14得票数 0
我正在对WCF服务进行代码审查。在每条消息的头中，我们注入服务稍后将用来构建到DB的连接字符串的数据。这是因为该服务将由许多不同的站点使用，每个站点都有自己的数据库，该服务必须查询这些数据库。我们使用wcf可扩展性。我们有一个自定义的MessageInspector，在收到请求后，从消息头中提取数据，创建上下文(实现IExtension)并将其添加到OperationContext.Current.Extensions中。在发送回复之前，将从Extencions集合中删除自定义上下文。
这是一个相当常见的模式，如下所述：
还有这里：
只要服务接收请求、处理请求、发送应答并接收下一个请求，所
浏览 22提问于2013-10-10得票数 17
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
