akka system.scheduler().scheduleAtFixedRate我可以在运行时更改Duration.ofMinutes的值吗？
akka system.scheduler().scheduleAtFixedRate是Akka框架中的一个方法，用于创建一个定时任务，按照固定的时间间隔重复执行指定的操作。在这个方法中，Duration.ofMinutes表示时间间隔，它是一个固定的值。
在运行时更改Duration.ofMinutes的值是不可行的，因为它是一个常量，表示了一个固定的时间间隔。如果需要在运行时动态改变时间间隔，可以考虑使用其他方式实现，比如使用变量来表示时间间隔，并在每次执行任务时动态获取变量的值。
关于Akka框架和定时任务的更多信息，可以参考腾讯云的Akka产品介绍页面：Akka产品介绍。
相关·内容
使用Scala 2.11.8，在返回()之前给出一个睡眠5的Future，我用1秒的超时调用了akka.pattern.ask：
import scala.concurrent.duration._
import scala.concurrent._
import akka.actor.ActorSystem
import scala.concurrent.ExecutionContext.Implicits.global
import akka.pattern.after
val system = ActorSystem.create()
after( FiniteDuration(1
浏览 1提问于2016-11-21得票数 0
回答已采纳
我必须实现一个进程，它从队列中轮询消息并将数据转发到http端点。通常，我认为最好的方法是使用Akka流(带有akka http)，因为它为您处理背压等。问题是，我必须在运行时(基于http调用)创建多个不同配置的管道。另一个要求是，应该可以在运行时动态地停止其中的一个管道，然后用另一个配置启动它。
目前，我不确定是否真的能够在运行时动态地旋转新的平行akka流管道(并删除和重新启动其中的一些管道)。对我来说，现在使用akka演员做这个听起来更好(基于队列使用者参与者和akka http参与者，我和我可以在运行时动态地创建一对)，但是要使用它们，我还必须手动实现背压等等。
你认为可以通过akk
浏览 1提问于2018-07-02得票数 0
回答已采纳
2回答
取消Akka调度程序
、、、
只是想知道取消日程的最好办法是什么。
目前，我使用一个链接到调度程序任务的var，并按如下方式取消它：
private var scheduterLink: akka.actor.Cancellable = null
def receive = {
case Test => {
if(...){scheduterLink.cancel}
}
还有更多的例子，如何在没有var链接的情况下做到这一点？
谢谢!
浏览 9提问于2016-03-21得票数 0
在测试使用参与者系统调度程序的参与者时，我遇到了一些问题。我曾期望调度程序在每次测试后系统被关闭时停止发送预定的消息，但这似乎没有发生。我打算将测试更改为使用模拟调度程序，但我仍然有几个问题：
为什么调度程序在其所属的系统关机后仍然发送消息？
在运行另一个测试之前，我可以向afterAll添加任何内容以正确关闭调度程序吗？
下面是一个使用Akka 2.1的工作示例：
import akka.testkit._
import akka.actor._
import scala.concurrent._
import scala.concurrent.duration._
impo
浏览 6提问于2013-12-29得票数 2
回答已采纳
如何在运行时更改计时器的周期？
Timer timer = new Timer();
timer.scheduleAtFixedRate(new TimerTask() {
public void run() {
// read new period
period = getPeriod();
doSomething();
}
}, 0, period);
浏览 8提问于2011-06-29得票数 12
回答已采纳
1回答
在akka-http路由中，我可以返回Future作为一个隐式转换为ToResponseMarshaller的响应。
有什么办法来处理这个未来的超时吗？还是路由级别的连接超时？或者一种方法是使用Await()函数？
现在，客户端可以永远等待响应。
complete {
val future = for {
response <- someIOFunc()
entity <- someOtherFunc()
} yield entity
future.onComplete({
case Success(result) =>
浏览 0提问于2015-03-28得票数 6
回答已采纳
1回答
我读过，对于如何让Akka与SLF4J一起工作仍然有些困惑。我的理解是正确的，总的过程是：
在运行时类路径中包括akka-slf4j模块，该类路径以过渡方式拉入slf4j-api
在运行时类路径中包括一个SLF4J后端，例如Logback
配置日志后端(不知何故，请参阅下面)
实例化和像普通一样使用SLF4J记录器
因此，首先，如果我错过或误解了上述任何步骤，请从纠正我开始！假设我或多或少是正确的，我仍然对以下两项一无所知：
我是配置Akka还是配置SLf4J“后端”(绑定)？(见下文)
为什么我不像平常一样实例化SLF4J记录器呢？(见下文)
配置
如
浏览 5提问于2015-06-01得票数 4
回答已采纳
1回答
我正在做一个POST请求与以下akka http请求端api。 Http().singleRequest(....) 我发现用于post的akka http不支持重试。 // max-retries = 3 // AKKA http default value is 5, and it doesn't work for POST request 那么在POST请求的情况下进行重试的最佳方法是什么？
浏览 22提问于2020-12-27得票数 3
回答已采纳
1回答
在运行几个小时之后，我有一个HTTP连接池挂起：
private def createHttpPool(host: String): SourceQueue[(HttpRequest, Promise[HttpResponse])] = {
val pool = Http().cachedHostConnectionPoolHttps[Promise[HttpResponse]](host)
Source.queue[(HttpRequest, Promise[HttpResponse])](config.poolBuffer, OverflowStrategy.dropNew
浏览 4提问于2017-02-27得票数 3
我正在使用Akka dispatcher/executor配置，我想向自己证明我所做的配置更改已经生效。因此，我希望在运行时检查调度程序的执行器参数(即parallelism-min、parallelism-factor、parallelism-max)。
我试过这个：
println(actorSystem.dispatcher.toString)
但是，它输出的只有：Dispatcher[akka.actor.default-dispatcher]，没有任何其他特定参数的细节。
可以打印出我的dispatcher的运行时配置吗？
浏览 0提问于2019-05-01得票数 0
遵循Akka tutorials https://doc.akka.io/docs/akka/current/typed/guide/tutorial_1.html，我修改了示例代码，使其每3秒向akka演员发送一条消息： scheduler.scheduleAtFixedRate(
initialDelay = Duration(0, TimeUnit.SECONDS),
interval = Duration(3, TimeUnit.SECONDS))(
runnable = task)
} 我无法安全地编译将Main中的消息返回从String更改为List
浏览 10提问于2020-06-04得票数 0
回答已采纳
1回答
我有自己的Actor，使用配置订阅Akka日志
loggers = ["path.MyActor"]
MyActor接收日志事件，但我希望在运行时停止接收它们。有没有办法做到这一点？(通过获取Akka日志的事件总线等)
浏览 19提问于2018-02-27得票数 1
回答已采纳
2回答
Akka 1.1.3文档指出“become方法对于许多不同的事情都很有用，但它的一个特别好的示例是它用于实现有限状态机的示例。”在运行时热插拔Akka参与者的实现还有哪些其他用例？
ActorRef特征中的actorClass方法被弃用，消息为“将被删除而不替换，面对become和unbecome没有任何意义。”有人能解释一下这个吗？
浏览 0提问于2011-09-14得票数 4
回答已采纳
我们有一个使用PlayFramework 2.5.4和MongoDB的Play-Project。我们想每天更新我们的数据库。现在，我们每次收到请求时都会检查，如果一天过去了，我们会进行更新。这导致了一些问题：
当前的玩家必须等待很长一段时间，直到请求完成。
可能会有一天没有更新(但我们希望每天都有更新，即使没有什么变化)。
我们必须修改我们插入的每一个请求。
因此，我已经找到了AKKA和旧的堆栈溢出问题(如)的文档。但是解决办法已经行不通了。
Akka.system().scheduler()
不受欢迎
system.scheduler()
给出编译错误()，我不知道是否缺
浏览 2提问于2016-06-30得票数 6
回答已采纳
我正在使用Akka，我希望在运行时构建一个定制的RunnableGraph，这取决于一些事先不知道的配置。
例如：
RunnableGraph.fromGraph(GraphDSL.create() { implicit builder =>
val source = builder.add(mySource)
if (A) {
builder.add(flowX)
} else {
builder.add(flowY)
}
ClosedShape
})
这是可能的吗，还是有一种更优雅的方法在运行时组成一个可运行的图，然后再传递和执行？
浏览 8提问于2022-07-27得票数 1
回答已采纳
我们正在考虑一种基于scala的Akka持久性应用的序列化方法。我们认为持久化事件可能会随着时间的推移而“进化”，因此我们希望支持模式演化，并且首先考虑Avro。
我们希望避免在每条消息中包含完整的模式。但是，在可预见的将来，这个Akka持久性应用程序是唯一一个序列化和反序列化这些消息的应用程序，因此我们认为不需要单独的模式注册表。
通过检查avro和各种scala库的文档，我看到了将模式包含在消息中的方法，以及如何通过使用模式注册中心来使用它“模式-无”，但是中间的情况如何呢？没有模式的正确方法是什么，但在某种程度上包括一个标识符，以便能够查找反序列化对象的正确模式(在本地部署的代码库中可用
浏览 1提问于2018-02-02得票数 3
回答已采纳
我开始用Scala学习Akka。我已经将lib akka-actor_2.10-2.3.10和typesafe-config-2.10.1导入到我的项目中。然而，它在运行时会抛出异常。详细信息：
Exception in thread "main" java.lang.NoSuchMethodError: com.typesafe.config.Config.getDuration(Ljava/lang/String;Ljava/util/concurrent/TimeUnit;)J
at akka.util.Helpers$ConfigOps$.akka$util$H
浏览 5提问于2015-05-05得票数 0
使用akka 1.3.1，我以前可以做这样的事情：
Actor.remote.start(config.server.host, config.server.port) Actor.remote.register("service", Actor.actorOf[ServiceHandler].start())
它将使用提供的主机/端口配置启动远程服务器，然后允许我稍后在运行时注册远程服务。有没有办法在Akka 2.0中获得这种行为，而不必在akka conf文件中预定义所有内容？
谢谢!
浏览 1提问于2012-04-27得票数 3
回答已采纳
我正在与Akka合作，目前我有以下协议。 ? 在我的协议中，我有一个服务器，它只负责创建资源(房间和gabblers)。这些资源被创建，然后被访问。接下来，我想通过一个键来找到相应的Gabbler来发送一条消息，但这一次来自一个类，这个类公开了一个不是ActorRef的接口/方法。我已经看过文档，令我难以置信的是，在角色系统中没有一个方法可以从层次结构中返回一个特定的角色来使用它。我已经读过前台部分了，虽然我不是很清楚，但我看到它又是面向演员的。在Akka中没有基于Actor的路径返回引用的方法吗？ package co.test;
import akka.actor.typed.
浏览 46提问于2021-01-13得票数 0
回答已采纳
1回答
我对安卓定时器的scheduleAtFixedRate选项有问题。
Timer timer = new Timer();
TimerTask myTimerTask = new TimerTask() {
public void run() {
...
}
};
timer.scheduleAtFixedRate(myTimerTask, 0, 5000);
这段代码对我来说是件坏事。它是在服务中执行的，所以每次调用timer方法时，都会创建一个新线程，并在旧线程仍在运行时执行相同的代码；这会造成性能问题。我需要每隔5秒运行run()方法中的代码，但我希望取消旧
浏览 0提问于2014-09-29得票数 0
1回答
我有一个具有Actor层次结构的现有ActorSystem。当Akka系统启动时，这些演员就会进来发挥作用。但是，我有一个要求，在运行时需要将Actor添加到ActorSystem中。是否可以在运行时将新的参与者定义动态添加到ActorSystem中？
浏览 0提问于2016-04-16得票数 1
我在运行时使用akka集群，我收到这样的日志
Received gossip status from [akka.tcp://test@ip:port], chunk [1]
of [1] containing [WeakUpdatesManagerCoordinatorState,
SeqUpdatesManagerCoordinatorState, EventBusMediatorCoordinatorState,
PresenceManagerCoordinatorState, shardakka-kv-MigrationsCoordinatorSt
浏览 6提问于2017-01-10得票数 0
回答已采纳
以下代码：
import org.scalamock.scalatest.MockFactory
import org.scalatest.FlatSpec
trait SomeTrait {
def getLongByInt(int: Int): Long
}
class TestScalaMock extends FlatSpec with MockFactory {
"Scala Mock" should "mock my trait" in {
val someTrait = mock[SomeTrait]
(someTrai
浏览 2提问于2014-11-14得票数 5
回答已采纳
我有一个actorA，它从dataActor获取数据，并将数据响应到requestActors：
class A extends Actor {
var data = Option.empty[Int]
val requestors = mutable.Set[ActorRef]
def receive = {
case data: Int =>
this.data = Some(data)
requestors.foreach {_ ! data}
case Request =>
if (data.isEmpt
浏览 0提问于2018-11-08得票数 0
回答已采纳
运行无法运行示例模板的akka-http-microservice Activator template错误: Activator中的akka-http-microservice
项目构建，但在运行时，无法访问URL，
http://localhost:9000/ip/8.8.8.8
获取
“内部服务器错误”
运行服务上的错误:错误默认-akka.actor.Default-dispatcher-10在阶段One2OneBidi中的错误:内部流在输入完成前完成。输出可能被截断。(akka.http.impl.util.One2OneBidiFlow$OutputTruncationExcep
浏览 2提问于2016-04-22得票数 0
2回答
我正在实现一个HTTP资源的迭代器，它可以恢复一个分页的元素列表，我试图用一个普通的Iterator来做这件事，但它是一个阻塞实现，而且由于我使用的是akka，这让我的分派器有点发疯。
我的意愿是使用akka-stream实现相同的迭代器。问题是我需要一点不同的重试策略。
该服务返回一个由id标识的元素列表，有时当我查询下一个页面时，该服务返回当前页面上的相同产品。
我目前的算法是这样的。
var seenIds = Set.empty
var position = 0
def isProblematicPage(elements: Seq[Element]) Boolean = {
v
浏览 8提问于2016-09-21得票数 3
回答已采纳
这里是Akka 。我的课：
class SomeActor extends UntypedActor {
// ...
}
class SomeMessage {
// ...
}
// Inside onReceive method for another actor:
Future<Fizz> fizzFut = Patterns.ask(someActor, someMsg, 500)
fizzFut.onComplete(new FizzHandler())
class FizzHandler extends akka.dispatch.OnCompl
浏览 3提问于2015-08-23得票数 3
回答已采纳
我构建了这个“节流式”任务运行程序，它收集HashMap中的一些数据，同时(每分钟)发送数据“离开”并清除HashMap。在我的测试中，我注意到执行器部分可以停止scheduleAtFixedRate，再也不会clear HashMap了。我假设这是因为我正在做的HashMap修改不是线程安全，它在没有恢复的情况下在run()内部崩溃。我正在两个线程中修改HashMap。有人能为我指出正确的方向如何优化我对HashMap的修改。
import java.time.Duration;
import java.util.HashMap;
import java.util.Map;
import j
浏览 18提问于2022-10-10得票数 0
回答已采纳
1回答
我得到了这个我不理解的编译错误：
[error] /Users/nicu/mooc-reactive/akkahttp-typed-actors-cluster-ORMap-followers/src/main/scala/followers/HttpServer.scala:43:76: type mismatch;
[error] found : akka.actor.typed.ActorRef[Res] => Req
[error] (which expands to) akka.actor.typed.ActorRef[scala.collection.immu
浏览 14提问于2020-02-11得票数 0
2回答
我现在有点绝望。我试图在Android (Eclipse中)下使用一个Akka项目(用scala编写)，但是无论我尝试什么，我都无法让它工作。
为了简单起见，我创建了两个项目:一个Akka项目，使用sbt eclipse创建，然后导入eclipse，以及一个使用项目创建向导的标准android项目。我可以从android代码中引用Akka代码，但在运行时，我总是得到一个NoClassDefFoundError。
如果有人能指出我做错了什么，或者我能做些什么，在我的Android应用中使用我的Akka项目，我会非常感激。
浏览 2提问于2013-04-04得票数 2
1回答
我目前正在阅读一些关于Akka的文章，但有一点到目前为止我还没有找到任何东西。在我享受强大的配置选项的同时，f.ex。要配置路由器以动态调整大小和使用给定的远程主机等，我还没有看到如何在运行时修改这些配置更改。
让问题更具体一些:假设我们有一台路由器，它被配置为路由到三台已知的远程主机(比如192.168.0.1、192.168.0.2、192.168.0.3)。现在，我将另一台机器添加到系统192.168.0.4。如果我理解正确，它将需要运行Akka微内核，然后我可以更改配置以包括这台机器。
然而，更改配置文件似乎需要重新启动整个系统(也许我弄错了？)。在这种情况下，有没有一种方法可以动态修
浏览 0提问于2012-12-14得票数 1
我知道我们可以使用资源字符串来存储值，但是可以在运行时更改这些值吗？
例如，我添加了两个新的资源元素username和password，并且希望在运行时更改这两个值。或者，有没有另一种存储值的方法？
浏览 1提问于2011-11-24得票数 14
为了我的硕士论文，我正在开发一个大型活动门票销售的应用程序框架。我的主要要求是可修改性、可伸缩性和性能。我的客户端(活动组织者)应该能够轻松地在运行时替换组件并添加功能。这种组成部分的一个例子可以是席位分配部分。
我的导师让我看看OSGi。松散耦合的捆绑的想法当然是有吸引力的。在寻找替代品的时候，我发现了阿克卡。这个框架承诺了很多事情，比如可伸缩性和高性能。我想知道Akka的演员概念是否适合我的可修改性要求。Akka似乎比OSGi更有效率，所以开发速度会更快。Akka似乎也更适合可伸缩性。有了OSGi，我会过得更艰难。
如果你在OSGi和Akka都有经验，你会推荐我哪一个？在比较这两种技术时，
浏览 7提问于2013-11-21得票数 2
回答已采纳
我正在使用Play Framework2.6.x创建一个简单的cron作业，它在特定的时间(例如凌晨3点)运行一个任务。但现在我在做一个简单的日程安排任务：
我创建了一个演员：
package actors;
import akka.actor.UntypedActor;
import org.slf4j.LoggerFactory;
public class DoSomethingActor extends UntypedActor {
private static final org.slf4j.Logger log = LoggerFactory.getLogger(DoSo
浏览 2提问于2019-08-12得票数 0
回答已采纳
我有一个方法，只有当它在最后的n毫秒内没有运行时，我才想运行它。
例如：
public boolean tooLong(int n) {
int timeSince = timeSinceLastExecution(tooLong);
//Returns an integer of how long it has been since the last time the tooLong method has been executed
if (timeSince > n)
return true;
return false;
}
浏览 8提问于2022-05-22得票数 0
回答已采纳
1回答
我已经启动了定时器和定时器。当用户在任务执行时更改系统时间时，continuously.It不会考虑周期时间。如何管理它。
timer.scheduleAtFixedRate(task, delay, period);
注:现在系统时间为当前time.Period为30秒。现在用户将系统时间从当前time.At更改为10分钟后，计时器任务不考虑该时间段。在一秒钟内，它将该任务执行20次。
当我使用
timer.schedule(task, delay, period);
而不是
timer.scheduleAtFixedRate(task, delay, period);
任务工作正常。如果
浏览 1提问于2014-04-10得票数 2
我有两个这样的ScheduledExecutorService：
private ScheduledExecutorService writeToLog = Executors.newSingleThreadScheduledExecutor();
writeToLog.scheduleAtFixedRate(
new Runnable() {
@Override
public void run() {
writeToLog();
浏览 0提问于2018-07-17得票数 1
2回答
我希望创建一个服务，其中它向特定的URL发出HTTP请求，如果它在1秒内没有得到结果，该请求将超时，然后它将使用另一个请求重试，最多重试3次。
如何在scala中实现这一点？
我正在寻找Akka HTTP和Play的WSClient的文档，但我找不到它被提到的任何地方。
注意:在请求对服务器产生副作用的情况下，我希望不成功的请求不产生副作用。如何实现此行为？这有可能吗？
浏览 3提问于2019-01-25得票数 2
1回答
我正在重构akka代码，在这种情况下我无法实例化参与者系统中的参与者。
我有一个BaseActor，它具有其他参与者使用的所有公共功能
trait baseActor extends Actor with timeout {
implicit val system = context.system
implicit val dispatcher = system.dispatchers.lookup("myCustomDispatcher")
implicit val ldapService = ldapSerice
}
我也有一个人员服务，主要是在Ldap上执行C
浏览 5提问于2021-08-20得票数 0
回答已采纳
1回答
我已经实现了shell，并从后面的代码填充了它的项。我想在运行时更改项的title属性，我要从资源文件中设置title属性，如下所示
Title = (String) Application.Current.Resources["MAIN_FLYER_SETTING_TEXT"],
在运行时，如果资源更改标题不根据该资源更改。这里有什么帮助吗？
浏览 2提问于2020-06-08得票数 1
回答已采纳
有人能告诉我为什么我会犯以下错误吗？
[error] HttpClient.scala:117: type mismatch;
[error] found : akka.stream.scaladsl.Sink[(akka.http.scaladsl.model.StatusCode, String),scala.concurrent.Future[(akka.http.scaladsl.model.StatusCode, String)]]
[error] required: akka.stream.Graph[akka.stream.SinkShape[(akka.http.sca
浏览 1提问于2017-09-07得票数 0
回答已采纳
我们可以在运行时更改物理体属性吗？我的代码是
local ground = display.newImage( "ground.png" )
ground.x = 160; ground.y = 445
physics.addBody( ground, "static", { friction=0.5, bounce=0.3 } )
我想在运行时将弹跳值更改为1.0，是否可能...
有人能帮我吗？
浏览 3提问于2013-06-14得票数 1
在试图编译错误消息中的代码行时，会发生以下错误。删除withStatus使代码编译。
误差/home/anton/code/flow-mobile/server/src/main/scala/in/flow/server/FlowServerStack.scala:108:型错配；
错误发现: akka.http.javadsl.model.HttpResponse
所需错误: akka.http.scaladsl.model.HttpResponse
错误r mapEntity {_ transformDataBytes errorFlow(ermsg) } withStatus代码
浏览 3提问于2017-02-27得票数 0
2回答
我正在使用akka库，并提供了一个部分函数，该函数将由actor在运行时通过热插拔实现。
akka热插拔采用PartialFunctionAny，Unit形式的参数。我将我的定义如下：
class Fake1Reader extends AbstractReader {
def read: PartialFunction[Any, Unit] = {
case readingRequest: ReadingRequest => {
var reading: Reading = new ReadingImpl(readingRequest.getResourceI
浏览 3提问于2011-10-19得票数 0
我正在尝试使用Akka TypedActors (1.1.2)。我有一个像这样的界面
trait Namespace {
def cellCount: Int
def isEmpty: Boolean
def cell(key: String): Option[CellOperations[_]]
def cellsLike(key: String): List[CellOperations[_]]
def updateOrCreateCell[T](n: String, v: Option[T]=None, d:List[DataOps[T]]=List.empty[D
浏览 0提问于2011-08-11得票数 2
1回答
请注意:尽管我更喜欢使用Akka的Java (这就是我正在使用的)的解决方案，但我对任何可行的解决方案都很满意，并且可能会想出如何将基于Scala的答案转换为Java。
我有一个Akka应用，有很多演员，其中两个是Fizz和Buzz。Fizz参与者可以接受两种类型的消息：
StartNewTimerTask；和
ResetAllTimerTasks
Buzz参与者只接受一条DoItNow消息。这些行为者与系统其他成员之间的信息流动如下：
任何东西(其他参与者，甚至是参与者系统之外的事件驱动组件)都可以在任何时候向StartNewTimerTask参与者发送Fizz消息。
浏览 0提问于2017-08-30得票数 0
回答已采纳
我正试图按照这里的指南运行Akka分布式工人项目，
在运行时，它会出现一系列错误消息失败。第一个引起我注意的是：
14:42:36.747 [ClusterSystem-akka.actor.default-dispatcher-4] ERROR akka.cluster.ClusterActorRefProvider - No root guardian at [akka.tcp://ClusterSystem@127.0.0.1:2554]
java.lang.IllegalArgumentException: Wrong protocol of [akka.tcp://ClusterSy
浏览 5提问于2019-11-20得票数 1
回答已采纳
2回答
Iam使用akka 2.1
我有两个问题:我有一个使用sbteclipse构建的eclipse scala项目。它工作得很好。
但我观察到，从eclipse编译不会复制我的resources。我的结构是：src/main/resources/application.conf src/main/resources/common.conf
编译后，我在目标中看不到这两个文件。在运行时，它会给我一个资源找不到的异常。
在从sbt编译时，它会按照预期执行。但第二个问题是:我有一个common.conf文件：
akka {
actor {
provider = "akka.remote.Re
浏览 0提问于2013-06-01得票数 1
回答已采纳
在我的单元测试中，我将ScheduledExecutoryService类的模拟实例注入到我试图测试的类中，以便在调用scheduleAtFixedRate(...)方法时，它返回一个模拟的Future。但是，由于某些原因，它总是返回null。有什么想法吗？
应用程序代码：
Future<?> t =
scheduledExecutorService.scheduleAtFixedRate(this, 10, 10, TimeUnit.SECONDS);
测试代码：
@Mock ScheduledExecutorService scheduledExecutorService;
浏览 2提问于2017-05-04得票数 3
2回答
我正在尝试创建一个演员，使用最新的Akka版本(现在是2.3.2)，使用JRuby。问题是，我一直收到这样的错误：
Java::JavaLang::IllegalArgumentException: erased Creator types are unsupported, use Props.create(actorClass, creator) instead
基本上，我遵循的是上的代码
我不能创建akka.japi.Creator，因为这需要通用信息，而这些信息在运行时被擦除( JRuby基本上是一个运行时无处不在的地方)。我已经尝试过了：
class GreetingActor <
浏览 3提问于2014-04-30得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
