Я пытаюсь создать несколько вершин параллельно:Как использовать последовательность в многопоточной среде
public static void main(String[] args) throws InterruptedException {
//create db and seq
ODatabaseDocumentTx db = new ODatabaseDocumentTx("memory:/TestDB");
db.create();
OSequenceLibrary seqLib = db.getMetadata().getSequenceLibrary();
seqLib.createSequence("testSeq",
OSequence.SEQUENCE_TYPE.ORDERED,
new OSequence.CreateParams().setStart(0L).setIncrement(1)
);
OrientGraphFactory factory = new OrientGraphFactory("memory:/TestDB", "admin", "admin").setupPool(1, 8);
//mt
Executor executor = Executors.newFixedThreadPool(8);
CountDownLatch latch = new CountDownLatch(1000);
for (int i = 1; i <= 1000; i++) {
executor.execute(() -> {
OrientGraph g = factory.getTx();
try {
OSequence seq = g.getRawGraph().getMetadata().getSequenceLibrary().getSequence("testSeq");
OrientVertex v = g.addVertex("TestClass");
v.setProperty("seq", seq.next());
latch.countDown();
} finally {
g.shutdown();
}
});
}
latch.await(5, TimeUnit.SECONDS);
System.exit(0);
}
И получить много исключений:
com.orientechnologies.orient.core.exception. OConcurrentModificationException: Невозможно ОБНОВИТЬ запись # 7: 0, потому что версия не самая последняя. Возможно, вы обновляете старую запись, или он был модифицирован другого пользователя (дб = v2 = v1 ваши)
Как использовать последовательность в мт среде правильно?
Спасибо, это не было очевидно для последовательности. – zella