class ConcurrentTraverseStrategy extends OltpTraverser
        implements TraverseStrategy {

    public ConcurrentTraverseStrategy(HugeGraph graph) {
        super(graph);
    }

    @Override
    public Map<Id, List<Node>> newMultiValueMap() {
        return new OltpTraverser.ConcurrentMultiValuedMap<>();
    }

    @Override
    public void traverseOneLayer(Map<Id, List<Node>> vertices,
                                 EdgeStep step,
                                 BiConsumer<Id, EdgeStep> biConsumer) {
        traverseIds(vertices.keySet().iterator(), (id) -> {
            biConsumer.accept(id, step);
        });
    }

    @Override
    public Set<Path> newPathSet() {
        return ConcurrentHashMap.newKeySet();
    }

    @Override
    public void addNode(Map<Id, List<Node>> vertices, Id id, Node node) {
        ((ConcurrentMultiValuedMap<Id, Node>) vertices).add(id, node);
    }

    @Override
    public void addNewVerticesToAll(Map<Id, List<Node>> newVertices,
                                    Map<Id, List<Node>> targets) {<FILL_FUNCTION_BODY>}
}

        ConcurrentMultiValuedMap<Id, Node> vertices =
                (ConcurrentMultiValuedMap<Id, Node>) targets;
        for (Map.Entry<Id, List<Node>> entry : newVertices.entrySet()) {
            vertices.addAll(entry.getKey(), entry.getValue());
        }
    
<methods>public void close() ,public static void destroy() <variables>private static final java.lang.String EXECUTOR_NAME,private static org.apache.hugegraph.util.Consumers.ExecutorPool executors