从 tinkergraph 进行多线程读取

Question

尝试从 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))
        }
    }
}

上面的代码在完全是单线程的情况下可以工作，但是一旦我引入了线程池，我就会遇到各种奇怪的错误。其中：

1. 顶点属性"type" 不存在。
2. java.lang.IndexOutOfBoundsException: Index: 0, Size: -1 尝试访问某些顶点属性时。
3. 验证规则在最初通过时失败。

从 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）从图读取时返回不一致的结果。

Answer 1

试试这个。替换

String prop = vertex.property("type");

有了这个

String type = vertex.value("type");

前者返回VertexProperty，而后者返回VertexProperty 的value，我认为这正是您要寻找的。​​p>

至于您的 #2 和 #3 项目符号，您需要提供更多详细信息。