尝试从 tinkergraph 进行多线程读取时，我遇到了非常奇怪的行为。我有以下情况：
Graph graph = TinkerGraph.open();
Set<Vertex> verticesAdded = randomGraph(graph);
verticesAdded是我在此randomGraph(graph)过程中添加的一组顶点。一旦有了这个列表，我就会检查这个顶点的内部属性，并根据该属性将顶点传递给线程以进行一些额外的工作。我遵循的过程大致是：
public class ValidateVerticies(){
private Set<Vertex> vertices;
private ExecutorService executor;
public ValidateVerticies(Set<Vertex> verticesAdded){
vertices = verticesAdded;
executor = Executors.newSingleThreadExecutor(); //Single just for testing purposes
}
public validate(){
for(Vertex vertex: vertices){
String prop = vertex.property("type");
if(type.equals("1"))
executor.submit(() -> validateRule1(vertex))
else if(type.equals("2"))
executor.submit(() -> validateRule2(vertex))
else if(type.equals("n"))
executor.submit(() -> validateRule3(vertex))
...
else if(type.equals("n"))
executor.submit(() -> validateRulen(vertex))
}
}
}
上面的代码在完全是单线程的情况下可以工作，但是一旦我引入了线程池，我就会遇到各种奇怪的错误。包含：
- 顶点属性
"type"不存在。 java.lang.IndexOutOfBoundsException: Index: 0, Size: -1尝试访问某些顶点属性时。- 验证规则在最初通过时失败。
从 tinkergraph 进行多线程读取时有什么微妙之处吗？
编辑：
我将尝试简化问题：以下工作：
public class ValidateVerticies(){
private Set<Vertex> vertices;
public ValidateVerticies(Set<Vertex> verticesAdded){
vertices = verticesAdded;
}
public validate(){
for(Vertex vertex: vertices){
String prop = vertex.property("type");
if(type.equals("1"))
validateRule1(vertex);
...
else if(type.equals("n"))
validateRulen(vertex);
}
}
}
虽然上面的多线程版本因 TinkerGraph 失败（同样适用于支持事务的 Titan），但在从图中读取时返回不一致的结果。