OrientDB多线程Concurrent Modification Exception等错误

Question

我正在编写一个将数据写入 orientDB (v 2.2.3) 上的图形的应用程序，该图形类似于以下内容：

我有将顶点添加到 C 顶点的线程，每个 C 顶点都有一个独立的线程，该线程负责添加具有边的 D 顶点。

每个线程都在处理一个单独的事务，我遇到了如下各种错误和异常：

com.orientechnologies.orient.core.exception.OStorageException: Error on commit
at      com.orientechnologies.orient.client.remote.OStorageRemote.baseNetworkOperation(OStorageRemote.java:253)
at com.orientechnologies.orient.client.remote.OStorageRemote.networkOperation(OStorageRemote.java:189)
at com.orientechnologies.orient.client.remote.OStorageRemote.commit(OStorageRemote.java:1271)
at com.orientechnologies.orient.core.tx.OTransactionOptimistic.doCommit(OTransactionOptimistic.java:549)
at com.orientechnologies.orient.core.tx.OTransactionOptimistic.commit(OTransactionOptimistic.java:109)
at com.orientechnologies.orient.core.db.document.ODatabaseDocumentTx.commit(ODatabaseDocumentTx.java:2665)
at com.orientechnologies.orient.core.db.document.ODatabaseDocumentTx.commit(ODatabaseDocumentTx.java:2634)
at com.tinkerpop.blueprints.impls.orient.OrientTransactionalGraph.commit(OrientTransactionalGraph.java:175)
at JSONManager$.commitGrap2(JSONManager.scala:371)
at JSONManager$$anonfun$main$$anon.run(JSONManager.scala:87)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
 .....
Caused by: java.util.ConcurrentModificationException
at java.util.LinkedHashMap$LinkedHashIterator.nextNode(LinkedHashMap.java:711)
at java.util.LinkedHashMap$LinkedValueIterator.next(LinkedHashMap.java:739)
at com.orientechnologies.orient.client.remote.OStorageRemote.execute(OStorageRemote.java:1284)
at com.orientechnologies.orient.client.remote.OStorageRemote.execute(OStorageRemote.java:1271)
at com.orientechnologies.orient.client.remote.OStorageRemote.execute(OStorageRemote.java:192)
at com.orientechnologies.orient.client.remote.OStorageRemote.baseNetworkOperation(OStorageRemote.java:224)
... 12 more

更新代码：

    val t: Runnable = new Runnable {
    override def run(): Unit = {
      graph = factory.getTx
      saveDUnits(dUnit, graph)
      commitGrap(graph)
      graph.shutdown()
    }
  };
  pool.execute(t)

def commitGrap(graph: OrientGraph): Unit = {
var retryCount = 0
while (retryCount < 10) {
  try {
    graph.commit()
    retryCount = 11
  } catch {
    case e: Exception => println("Commit Error")
      e.printStackTrace()
      var sleepTime = 50
      if (retryCount > 5) {
        sleepTime = 6000
      }
      Thread.sleep(sleepTime);
  } 
  retryCount = retryCount + 1
}

}

Answer 1

最后我发现了错误，问题出在创建 OrientGraphFactory 实例时，非线程安全工厂的创建方式如下

var factory: OrientGraphFactory = new OrientGraphFactory("remote:106.140.20.233/test", "root", "123")

线程安全工厂创建如下：

var factory: OrientGraphFactory = new OrientGraphFactory("remote:106.140.20.233/test", "root", "123").setupPool(1, 20)

我错过了添加 .setPool(1,20)

就是这样

OrientDB多线程Concurrent Modification Exception等错误

OrientDB multithread Concurrent Modification Exception and other errors

orientdb