用于阻塞请求的Akka执行元池
Akka执行元池（Akka Dispatchers）是Akka框架中的一个重要概念，用于管理和调度执行任务的线程池。它主要用于处理阻塞式的请求，以避免阻塞整个系统。
概念： Akka执行元池是一种线程池，用于执行Akka框架中的任务。它通过将任务分配给可用的线程来实现并发执行，从而提高系统的吞吐量和响应性能。
分类： Akka执行元池可以根据不同的需求进行分类，常见的分类包括：
- ForkJoinPool：基于工作窃取算法的线程池，适用于CPU密集型任务。
- ThreadPoolExecutor：基于线程池的执行元池，适用于IO密集型任务。
- Dispatcher：自定义的执行元池，可以根据具体需求进行配置和调整。
优势： 使用Akka执行元池的优势包括：
- 提高系统的并发性能：通过并发执行任务，充分利用系统资源，提高系统的吞吐量和响应性能。
- 避免阻塞：对于阻塞式的请求，使用执行元池可以将其分配给可用的线程，避免整个系统被阻塞。
- 灵活配置：Akka执行元池支持灵活的配置选项，可以根据具体需求进行调整，以满足不同场景下的性能要求。
应用场景： Akka执行元池适用于以下场景：
- Web服务器：用于处理大量的并发请求，提高系统的并发处理能力。
- 分布式系统：用于处理分布式系统中的任务调度和并发执行。
- 数据库访问：用于并发执行数据库访问操作，提高系统的数据库访问性能。
推荐的腾讯云相关产品： 腾讯云提供了一系列与云计算相关的产品和服务，以下是一些推荐的产品：
- 云服务器（CVM）：提供弹性计算能力，用于部署和运行应用程序。
- 云数据库MySQL版（CDB）：提供高可用、可扩展的数据库服务，用于存储和管理数据。
- 云原生容器服务（TKE）：提供容器化应用的部署和管理，支持快速扩展和自动化运维。
- 人工智能平台（AI Lab）：提供丰富的人工智能算法和工具，用于开发和部署人工智能应用。
- 物联网平台（IoT Hub）：提供物联网设备的连接和管理，支持海量设备的数据采集和分析。
产品介绍链接地址：
- 云服务器（CVM）：https://cloud.tencent.com/product/cvm
- 云数据库MySQL版（CDB）：https://cloud.tencent.com/product/cdb
- 云原生容器服务（TKE）：https://cloud.tencent.com/product/tke
- 人工智能平台（AI Lab）：https://cloud.tencent.com/product/ai
- 物联网平台（IoT Hub）：https://cloud.tencent.com/product/iothub
相关·内容
2回答
用于阻塞请求的Akka执行元池
、、、、
我正在尝试使用线程池来发出阻塞请求。问题是，每个请求都阻塞了整个池，并且项目是按顺序处理的。我甚至不确定这是否可能。Java
Props props = Props.create(CityDataProcessorActor.class, psRespHolder).withDispatcher("akka.actor.city-dispatcher
浏览 13提问于2017-02-17得票数 1
我需要介绍一种新的消息传递类型(PushNotification)，它包括让每个请求使用一个REST API (它还将处理数百万个请求)。我认为使用Webservice是一个阻塞操作，所以从我所读到的内容来看，我需要为这个新的Actor添加一个单独的分派器，我的问题是，它一定要像这里提到的那样是具有固定池大小的线程池执行器吗？(参见https:/
浏览 21提问于2019-06-14得票数 1
我试图从概念上理解为什么在Play Framework2.0中，为web服务调用调用WS.url().get()被认为是一种最佳实践，但是如果您将任何其他阻塞调用(如JDBC调用)包装在承诺中，那么建议您在默认执行上下文之外的执行上下文中这样做我知道，默认情况下，Play Framework的线程池被配置为每个内核都有一个线程，每个控制器都希望运行完全非阻塞的代码。出于这个原因，如果在控制器中进行阻塞调用--比如对web服务--那么您
浏览 0提问于2014-08-30得票数 3
回答已采纳
1回答
来自：
播放默认线程池--这是默认线程池，其中执行Play Framework中的所有应用程序代码，不包括一些迭代代码。它是一个Akka调度程序，可以通过配置Akka进行配置，如下所述。将阻塞数据库调用包装在Future中会带来好处吗?对Future本身的调用由async控制器包装(返回它)，以便让默认线程池处理其他用户请求？它只会将阻塞代码移动到另一个线程中(从一个专用的Exe
浏览 1提问于2014-07-06得票数 6
回答已采纳
1回答
我有一个akka系统，其中99%的请求涉及阻塞DB调用。我想知道这种系统在单独的dispatcher\线程池中执行阻塞操作是否有什么好处，正如最佳实践中所描述的那样。虽然akka线程将处于空闲等待状态，但线程池任务队列可以是溢出内存，也可以是开始拒绝新任务，而行为者以某种方式处理这些任务。
我明白这是一个常见的问题，但我找不到任何有关的文章或讨论。
浏览 3提问于2017-08-27得票数 0
回答已采纳
1回答
我有一个简单的Akka HTTP应用程序，它是使用websocket的。我的请求处理程序有阻塞调用(比如JDBC)。因此，我需要使用一些固定大小的线程池来处理这些代码。当我运行我的应用程序并执行线程转储时，我看到两个线程名：
Routes-akka.actor.def
浏览 0提问于2019-02-11得票数 1
回答已采纳
Play2使用bonecp作为数据库连接池。
一个从池获得连接并处理调用的参与者。默认情况下，30个连接可用于bonecp池。看:文档在，代码在
让我们假设我们有一个高负载的应用程序，它必须处理许多并发请求。在我的测试中，我遇到了默认配置的50+并发请求的问题。许多
浏览 0提问于2013-12-29得票数 1
2回答
实际上，数据库操作是阻塞的，而我们在AKKA中尽量不阻塞。3-我们是否应该将两者结合起来，并让DatabaseActors在每次请求它们时从池中请求一个新的连接。如果不是，让连接一直处于打开状态不是一件
浏览 0提问于2015-02-17得票数 22
我有几个数据流，大约每分钟醒来一次，从DB中提取一些文档，执行一些操作，最后向SNS发送消息。[INFO] [06/04/2020 07:50:32.326] [default-akka.actor.default-dispatcher-5] [default[INFO] [06/04/2020 07:51:32.666] [default-akka.actor.default-dispatcher-15] [default/
浏览 1提问于2020-06-04得票数 0
回答已采纳
2回答
我正在使用Play框架进行编码，并希望使用Akka来实现ASYC功能并实现实时结果。但我不确定将Akka与使用线程的API集成是否有意义。第三方接收消息，使用线程执行命令，并做任何需要做的事情。我不是真的担心它是怎么做的。只是指出它使用线程。
请您分享Akka在这个用例中可以创造价值的地方吗？谢谢一堆
浏览 2提问于2012-10-19得票数 0
1回答
线程计数过多问题
、、
我已经理解了“阻塞io”的缺陷，所以我创建了一个用于阻塞io的线程池，并在阻塞线程执行的所有Future块中使用它。线程池的定义如下。'application-akka.actor.default-dispatcher-#‘的线程下运行，其中‘’application blocking io-di
浏览 3提问于2018-06-01得票数 0
我在线程池服务阻塞请求中有一个线程。fork-join-executor { parallelism-max = 1}
理论上，如果上面的请求同时接收100个请求，那么预期的行为应该是:1请求应该休眠( 100 )，其余的99请求应该被拒绝(或者排队直到超时？)。但是，我注意到创建了额外的工作线程来为其余的<
浏览 2提问于2014-07-04得票数 6
回答已采纳
1回答
每个工作参与者执行几个HTTP连接。我从几个来源了解到，如果参与者执行一些阻塞操作，那么最好将阻塞操作封装到这个构造中： blocking { }}
但后来我读到了关于在Akka中处理阻塞操作的，我很惊讶这个主题建议仅仅使用路由器进行阻塞操作(作为将来的替代)：
在一个参与者(或一组由路由器管理<em
浏览 2提问于2015-05-27得票数 1
回答已采纳
我有一个ASP.NET应用程序，它访问一个包装了字典的类，可以在页面请求处理期间访问它。Akka.NET执行元还会在初始化期间获得对该类实例的引用，并可以随时访问该类。在不中断Akka.NET流程的情况下同步对该字典的访问的最好方法是什么？使用.NET监视器可以以某种方式破坏Akka.NET线程池吗？我不能将整个应用程序逻辑更改为actor，并将缓存包装在actor中(目前还不能)
浏览 2提问于2016-02-17得票数 2
从医生那里：
这让我对如何调整我的how应用程序感到有点困惑。具体来说，由于我的应用程序有大量的</
浏览 6提问于2014-10-03得票数 6
回答已采纳
我们观察到，在增加对我们服务的并发http调用时，线程计数(akka.actor.default-dispatcher)一直在增加(参见visualVM的截图)。此外，在请求停止后，线程计数也不会下降。其中大部分仍留在帕克州。这种按比例增加的线程是预期的行为吗？我们如何控制这一点，并重用相同的参与者或在请求得到服务后杀死这些参与者。parallelism-max = 6 throughput = 1 } VisualVM SS of
浏览 27提问于2021-04-04得票数 1
回答已采纳
1回答
Akka文档说：
在Future中执行阻塞调用，确保在任何时间点都有这样的调用次数的上限(提交无限制的此类任务数将耗尽内存或线程限制)。在Future中执行阻塞调用，为线程池提供对线程数量的上限，这对于运行应
浏览 2提问于2013-04-11得票数 9
回答已采纳
1回答
在play 2.1中异步不起作用
、、、、
thread open Promise<String> promiseOfString = play.libs.Akka.futurehttp请求的线程。但它的执行与syncFreeze()没有任何不同。对于这两种方法，一旦调用8次，就不能加载其他页面，这表明所有服务请求的线程都已被阻塞。但这对我来说没有意义--这应该是async()方法<em
浏览 4提问于2014-01-13得票数 0
1回答
线程池执行器使用用于未来任务的线程数。它至少分配一个线程，直到run()或调用()返回为止。2)由于线程不会阻塞IO，它们将退出run/call方法。然后谁负责调用他们的处理程序。我的问题是如何使用基于Java的HTTP客户端请求和线程池(因为我们需要发出大量的HTTP<e
浏览 1提问于2013-05-16得票数 0
1回答
这里是我的用例：
我想要创建一个大小为x的平衡池路由器(x是在运行时确定的实例/路由器的数量)，每个路由器都有自己的专用线程。每个路由器都将执行阻塞操作。Akka文档解释说，您不能更改平衡池的调度程序。这就排除了使用固定调度程序的选项(这将完全满足我的需要，每个路由器的线程池大小为1)。在需要路由器执行</em
浏览 9提问于2016-12-16得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
