用于阻塞请求的Akka执行元池

文章/答案/技术大牛

发布

2回答

java、scala、akka、actor、blocking

我正在尝试使用线程池来发出阻塞请求。问题是，每个请求都阻塞了整个池，并且项目是按顺序处理的。我甚至不确定这是否可能。Java Props props = Props.create(CityDataProcessorActor.class, psRespHolder).withDispatcher("akka.actor.city-dispatcher

浏览 13提问于2017-02-17得票数 1

1回答

Akka -配置使用REST API服务的Actor的最佳方法(阻塞操作)

scala、concurrency、parallel-processing、akka

我需要介绍一种新的消息传递类型(PushNotification)，它包括让每个请求使用一个REST API (它还将处理数百万个请求)。我认为使用Webservice是一个阻塞操作，所以从我所读到的内容来看，我需要为这个新的Actor添加一个单独的分派器，我的问题是，它一定要像这里提到的那样是具有固定池大小的线程池执行器吗？(参见https:/

浏览 21提问于2019-06-14得票数 1

1回答

我试图从概念上理解为什么在Play Framework2.0中，为web服务调用调用WS.url().get()被认为是一种最佳实践，但是如果您将任何其他阻塞调用(如JDBC调用)包装在承诺中，那么建议您在默认执行上下文之外的执行上下文中这样做我知道，默认情况下，Play Framework的线程池被配置为每个内核都有一个线程，每个控制器都希望运行完全非阻塞的代码。出于这个原因，如果在控制器中进行阻塞调用--比如对web服务--那么您

浏览 0提问于2014-08-30得票数 3

回答已采纳

1回答

播放Framework2.x并阻塞数据库调用

scala、asynchronous、playframework、nonblocking、playframework-2.3

来自：播放默认线程池--这是默认线程池，其中执行Play Framework中的所有应用程序代码，不包括一些迭代代码。它是一个Akka调度程序，可以通过配置Akka进行配置，如下所述。将阻塞数据库调用包装在Future中会带来好处吗?对Future本身的调用由async控制器包装(返回它)，以便让默认线程池处理其他用户请求？它只会将阻塞代码移动到另一个线程中(从一个专用的Exe

浏览 1提问于2014-07-06得票数 6

回答已采纳

1回答

Akka和封锁行动

asynchronous、akka、blocking

我有一个akka系统，其中99%的请求涉及阻塞DB调用。我想知道这种系统在单独的dispatcher\线程池中执行阻塞操作是否有什么好处，正如最佳实践中所描述的那样。虽然akka线程将处于空闲等待状态，但线程池任务队列可以是溢出内存，也可以是开始拒绝新任务，而行为者以某种方式处理这些任务。我明白这是一个常见的问题，但我找不到任何有关的文章或讨论。

浏览 3提问于2017-08-27得票数 0

回答已采纳

1回答

如何为Akka HTTP配置特定的调度程序？

multithreading、scala、akka、threadpool、akka-http

我有一个简单的Akka HTTP应用程序，它是使用websocket的。我的请求处理程序有阻塞调用(比如JDBC)。因此，我需要使用一些固定大小的线程池来处理这些代码。当我运行我的应用程序并执行线程转储时，我看到两个线程名： Routes-akka.actor.def

浏览 0提问于2019-02-11得票数 1

回答已采纳

2回答

使用play 2.2.1和JPA的线程死锁

playframework、playframework-2.0、akka

Play2使用bonecp作为数据库连接池。一个从池获得连接并处理调用的参与者。默认情况下，30个连接可用于bonecp池。看:文档在，代码在让我们假设我们有一个高负载的应用程序，它必须处理许多并发请求。在我的测试中，我遇到了默认配置的50+并发请求的问题。许多

浏览 0提问于2013-12-29得票数 1

2回答

AKKA演员与DataBase运营

scala、database-connection、akka、connection-pooling、actor

实际上，数据库操作是阻塞的，而我们在AKKA中尽量不阻塞。3-我们是否应该将两者结合起来，并让DatabaseActors在每次请求它们时从池中请求一个新的连接。如果不是，让连接一直处于打开状态不是一件

浏览 0提问于2015-02-17得票数 22

1回答

当使用主机连接池时，“池现在按请求关闭”意味着什么？

scala、akka-http

我有几个数据流，大约每分钟醒来一次，从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回答

从AKKA这样的Actor模型框架调用基于线程的API

java、sockets、playframework、socket.io、akka

我正在使用Play框架进行编码，并希望使用Akka来实现ASYC功能并实现实时结果。但我不确定将Akka与使用线程的API集成是否有意义。第三方接收消息，使用线程执行命令，并做任何需要做的事情。我不是真的担心它是怎么做的。只是指出它使用线程。请您分享Akka在这个用例中可以创造价值的地方吗？谢谢一堆

浏览 2提问于2012-10-19得票数 0

1回答

线程计数过多问题

multithreading、playframework、dispatcher

我已经理解了“阻塞io”的缺陷，所以我创建了一个用于阻塞io的线程池，并在阻塞线程执行的所有Future块中使用它。线程池的定义如下。'application-akka.actor.default-dispatcher-#‘的线程下运行，其中‘’application blocking io-di

浏览 3提问于2018-06-01得票数 0

2回答

Play Framework:当请求超过可用线程时会发生什么

multithreading、scala、playframework-2.0、threadpool

我在线程池服务阻塞请求中有一个线程。fork-join-executor { parallelism-max = 1} 理论上，如果上面的请求同时接收100个请求，那么预期的行为应该是:1请求应该休眠( 100 )，其余的99请求应该被拒绝(或者排队直到超时？)。但是，我注意到创建了额外的工作线程来为其余的<

浏览 2提问于2014-07-04得票数 6

回答已采纳

1回答

Akka路由器、期货和阻塞操作

scala、akka

每个工作参与者执行几个HTTP连接。我从几个来源了解到，如果参与者执行一些阻塞操作，那么最好将阻塞操作封装到这个构造中： blocking { }} 但后来我读到了关于在Akka中处理阻塞操作的，我很惊讶这个主题建议仅仅使用路由器进行阻塞操作(作为将来的替代)：在一个参与者(或一组由路由器管理<em

浏览 2提问于2015-05-27得票数 1

回答已采纳

2回答

在Akka.NET中同步对ActorSystem外部对象的访问的最佳方式是什么？

asp.net、akka.net

我有一个ASP.NET应用程序，它访问一个包装了字典的类，可以在页面请求处理期间访问它。Akka.NET执行元还会在初始化期间获得对该类实例的引用，并可以随时访问该类。在不中断Akka.NET流程的情况下同步对该字典的访问的最好方法是什么？使用.NET监视器可以以某种方式破坏Akka.NET线程池吗？我不能将整个应用程序逻辑更改为actor，并将缓存包装在actor中(目前还不能)

浏览 2提问于2016-02-17得票数 2

2回答

如何使用适当的线程池对Play Framework应用程序进行优化？

scala、playframework-2.3

从医生那里：这让我对如何调整我的how应用程序感到有点困惑。具体来说，由于我的应用程序有大量的</

浏览 6提问于2014-10-03得票数 6

回答已采纳

1回答

在lagom中:随着并发http调用的增加，线程计数(akka.actor.default-dispatcher)不断增加。如何控制这种行为？

akka、lagom

我们观察到，在增加对我们服务的并发http调用时，线程计数(akka.actor.default-dispatcher)一直在增加(参见visualVM的截图)。此外，在请求停止后，线程计数也不会下降。其中大部分仍留在帕克州。这种按比例增加的线程是预期的行为吗？我们如何控制这一点，并重用相同的参与者或在请求得到服务后杀死这些参与者。parallelism-max = 6 throughput = 1 } VisualVM SS of

浏览 27提问于2021-04-04得票数 1

回答已采纳

1回答

Scala中阻塞看涨的期货

scala、concurrency、future

Akka文档说：在Future中执行阻塞调用，确保在任何时间点都有这样的调用次数的上限(提交无限制的此类任务数将耗尽内存或线程限制)。在Future中执行阻塞调用，为线程池提供对线程数量的上限，这对于运行应

浏览 2提问于2013-04-11得票数 9

回答已采纳

1回答

在play 2.1中异步不起作用

java、multithreading、http、asynchronous、playframework

thread open Promise<String> promiseOfString = play.libs.Akka.futurehttp请求的线程。但它的执行与syncFreeze()没有任何不同。对于这两种方法，一旦调用8次，就不能加载其他页面，这表明所有服务请求的线程都已被阻塞。但这对我来说没有意义--这应该是async()方法<em

浏览 4提问于2014-01-13得票数 0

1回答

带有线程池的Java Http客户端请求

java、multithreading、threadpool、nio、threadpoolexecutor

线程池执行器使用用于未来任务的线程数。它至少分配一个线程，直到run()或调用()返回为止。2)由于线程不会阻塞IO，它们将退出run/call方法。然后谁负责调用他们的处理程序。我的问题是如何使用基于Java的HTTP客户端请求和线程池(因为我们需要发出大量的HTTP<e

浏览 1提问于2013-05-16得票数 0

1回答

变尺寸线程池-执行器的Akka平衡池

scala、akka、threadpoolexecutor、akka-actor、akka-dispatcher

这里是我的用例：我想要创建一个大小为x的平衡池路由器(x是在运行时确定的实例/路由器的数量)，每个路由器都有自己的专用线程。每个路由器都将执行阻塞操作。Akka文档解释说，您不能更改平衡池的调度程序。这就排除了使用固定调度程序的选项(这将完全满足我的需要，每个路由器的线程池大小为1)。在需要路由器执行</em

浏览 9提问于2016-12-16得票数 2

点击加载更多