Scala中的并发Akka代理

import akka.actor._
import akka.agent._
import scala.concurrent.ExecutionContext.Implicits.global

object AgentTester extends App {
// Create the system for the actors that power the agents
implicit val system = ActorSystem("ActorSystem")

// Create an agent for each int between 1 and 10
val agents = Vector.tabulate[Agent[Int]](10)(x=>Agent[Int](1+x))

// Define a function for each agent to execute
def printRecur(a: Agent[Int])(x: Int): Int = {
    // Print out the stored number and sleep.
    println(x)
    Thread.sleep(250)

    // Recur the agent
    a sendOff printRecur(a) _

    // Keep the agent's value the same
    x
}

// Start each agent
for(a <- agents) {
    Thread.sleep(10)
    a sendOff printRecur(a) _
}
}

上面的代码创建了一个代理,其中包含1到10之间的每个整数.底部的循环将printRecur函数发送给每个代理.程序的输出应该显示每隔一刻钟打印出的数字1到10(尽管不是以任何顺序).但是,出于某种原因,我的输出仅显示输出的数字1到4.

是否有更规范的方式在Akka中使用代理可以工作？我来自clojure背景并且之前已成功使用此模式,因此我在Scala中天真地使用了相同的模式.