- Java 双重比较
- java - 比较器与 Apache BeanComparator
- Objective-C 完成 block 导致额外的方法调用?
- database - RESTful URI 是否应该公开数据库主键?
我必须使用 hasNext() 和 next() 方法实现一个 Iterator 接口(interface)(由 Java API 定义),它应该返回源自异步处理的 HTTP 响应(使用 Akka actor 处理)的结果元素。
必须满足以下要求:
我还没有研究过 Java 8 流或 Akka 流。但由于我基本上必须遍历队列(有限流),所以我怀疑是否有任何合适的解决方案。
目前,我的 Scala 实现 stub 使用 java.util.concurrent.BlockingQueue 并且看起来像这样:
class ResultStreamIterator extends Iterator[Result] {
val resultQueue = new ArrayBlockingQueue[Option[Result]](100)
def hasNext(): Boolean = ??? // return true if not done yet
def next(): Result = ??? // take() next element if not done yet
case class Result(value: Any) // sent by result producing actor
case object Done // sent by result producing actor when finished
class ResultCollector extends Actor {
def receive = {
case Result(value) => resultQueue.put(Some(value))
case Done => resultQueue.put(None)
}
}
}
我使用 Option[Result] 来指示结果流的结尾为 None。我尝试过查看下一个元素并使用“完成”标志,但我希望有更简单的解决方案。
奖励问题:
最佳答案
以下代码将满足要求。Actor 的字段可以在 Actor 的接收器中安全地修改。所以resultQueue不应该在Iterator的域,而应该在Actor的域。
// ResultCollector should be initialized.
// Initilize code is like...
// resultCollector ! Initialize(100)
class ResultStreamIterator(resultCollector: ActorRef) extends Iterator[Result] {
implicit val timeout: Timeout = ???
override def hasNext(): Boolean = Await.result(resultCollector ? HasNext, Duration.Inf) match {
case ResponseHasNext(hasNext) => hasNext
}
@scala.annotation.tailrec
final override def next(): Result = Await.result(resultCollector ? RequestResult, Duration.Inf) match {
case ResponseResult(result) => result
case Finished => throw new NoSuchElementException("There is not result.")
case WaitingResult => next()// should be wait for a moment.
}
}
case object RequestResult
case object HasNext
case class ResponseResult(result: Result)
case class ResponseHasNext(hasNext: Boolean)
case object Finished
case object WaitingResult
case class Initialize(expects: Int)
// This code may be more ellegant if using Actor FSM
// Acotr's State is (beforeInitialized)->(collecting)->(allCollected)
class ResultCollector extends Actor with Stash {
val results = scala.collection.mutable.Queue.empty[Result]
var expects = 0
var counts = 0
var isAllCollected = false
def beforeInitialized: Actor.Receive = {
case Initialize(n) =>
expects = n
if (expects != 0) context become collecting
else context become allCollected
unstashAll
case _ => stash()
}
def collecting: Actor.Receive = {
case RequestResult =>
if (results.isEmpty) sender ! WaitingResult
else sender ! ResponseResult(results.dequeue())
case HasNext => ResponseHasNext(true)
case result: Result =>
results += result
counts += 1
isAllCollected = counts >= expects
if (isAllCollected) context become allCollected
}
def allCollected: Actor.Receive = {
case RequestResult =>
if (results.isEmpty) sender ! Finished
else sender ! ResponseResult(results.dequeue())
case HasNext => ResponseHasNext(!results.isEmpty)
}
def receive = beforeInitialized
}
关于java - 使用 hasNext() 和 next() 遍历异步生成的元素流,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/30138672/
有人可以告诉我,如果 (ListIterator it = listIterator(); it.hasNext(); )部分代码应写为 for (ListIterator it = list.lis
我试图调用 hasNext Velocity 模板中的方法,以便根据 foreach 循环中的位置影响行为 - 仅 hasNext没有按照文档工作。 这是 Velocity 用户指南的片段,关于 ha
我正在尝试读取文件并提取最大的数字。我想读完文件,但 hasNext() 一直给我 true 。当我尝试将其更改为 hasNextInt() 时,即使我的字符为整数,它也永远不会进入。如何跳出循环并正
我想使用下面的代码片段来允许用户一次输入四个值,并用空格分隔,在这种情况下,它们将被单独捕获并分配给变量。或者,用户可以一次输入一个值,同时等待每个值之间的提示。如果 if(in.hasNext())
Scanner scanner = new Scanner(System.in); // check if the scanner has a token System.out.pri
我正在一个在线编程竞赛网站上做一道编程题。说明是,当用户有输入要输入时,它应该继续获取用户输入(不是来自文件)。代码大致如下: public static void main(String[] arg
我对以下与 Java OOP 和 Java API/源代码安排有关的情况感到困惑。基于Oracle's Java 8 API , hasNext() 是一个抽象方法,但是我找不到 hasNext()
我正在编写一个迭代器,它通过委托(delegate)给“当前”列表自己的迭代器来迭代列表列表。 (不,我不是,但这是一个简单的例子)。现在,当我到达一个列表的末尾时,我需要更新委托(delegate)
我是 Java 的新手,正在尝试这个问题,我应该输入一对值(两个字符串一次一个),这意味着循环直到我退出使用ctrl z。只有等级将用于开关;该名称只是一个虚拟值。 我的预期输出是: 输入名称:(然后
var intList = Iterator(range(1,10)) println("data"+intList) println(intList.hasNext) 最后一行给出 True,而对于
所以我是编程的初学者,我想弄清楚问题出在哪里 以下函数。问题出在 scan.hasNext() 方法上 我有两个 println 语句(一个在我进行扫描之后,一个在第二种方法上)告诉我 scan.ha
这个问题已经有答案了: Using Mockito with multiple calls to the same method with the same arguments (14 个回答) 已关
我在尝试理解如何循环用户将给出的键盘输入文本行时遇到问题,例如: 阿尼卡 14 丹 16 我想读取每个标记并分配给字符串名称、整数、年龄、字符串名称、整数年龄。以该顺序。然而,这很容易,如果用户输入阿
在迭代器循环中不建议使用 iterator.hasNext() 吗? 例如,我想将值 obj 设置为列表的每个元素。我可以使用以下代码或通过在循环中使用 hasNext() 使其更具可读性。 int
我正在尝试让 Java 使用 hasNext()、hasNextLine() 和 while 循环来计算文本文件中的行数,尽管我似乎是遇到一些麻烦。该程序将持续运行,我相信它陷入了无限循环。如果有人可
我想从 CSV 文件恢复对象。我需要知道扫描仪是否有 2 个下一个值:scanner.hasNext() 问题是我的访问构造函数有两个参数,我需要确保我的 csv 文件中至少还剩下 2 个。 相关代码
我想要使用的日志文件是制表符分隔的,如下所示: 2019-06-06 10:01:02 1.0 2019-06-06 10:25:12 100.0 2019-06-06 11:02:32
我正在尝试在递归方法中使用迭代器。如果列表中没有下一个元素,则应退出该方法。但是,如果光标位于最后一个位置,则使用 iterator.hasNext() 检查返回 true,我除外 false? 有什
我应该编写一个程序来处理用户输入并将其翻译成 Pig Latin 并打印出来。我翻译成 pig 拉丁语的指令是: Pig Latin 是英语,其首辅音移至每个单词的末尾,后跟“ay”。以元音开头的单词
我有一个作业程序,但我无法弄清楚最后的花絮。它需要能够接受一大段“DNA”代码。给出的样本在 100,000+ 范围内。我一开始就写了适合小样本、一行的内容,非常棒。助教告诉我,我应该能够添加一个 w
我是一名优秀的程序员,十分优秀!