scala – 在Neo4j中创建多线程节点

这是一段Scala代码,可以在并行集合的帮助下对其进行测试：

import org.neo4j.kernel.EmbeddedGraphDatabase

object Main extends App {

    val total = 1000000
    val batchSize = 10000

    val db = new EmbeddedGraphDatabase("neo4yay")

    Runtime.getRuntime().addShutdownHook(
        new Thread(){override def run() = db.shutdown()}
    )

    (1 to total).grouped(batchSize).toSeq.par.foreach(batch => {

        println("thread %s,nodes from %d to %d"
            .format(Thread.currentThread().getId,batch.head,batch.last))

        val transaction = db.beginTx()
        try{
            batch.foreach(db.createNode().setProperty("Number",_))
        }finally{
            transaction.finish()
        }
    })
}

以下是构建和运行它所需的build.sbt行：

scalaVersion := "2.9.2"

libraryDependencies += "org.neo4j" % "neo4j-kernel" % "1.8.M07"

fork in run := true

通过在外部foreach之前删除和添加.par调用,可以在并行和顺序模式之间切换.然后控制台输出清楚地显示.par执行确实是多线程的.

为了排除此代码中可能出现的并发问题,我还尝试了基于actor的实现,结果大致相同(分别为顺序和并行版本分别为6秒和7秒).

所以,问题是：我做错了什么或者这是Neo4j的限制吗？
谢谢！