fix: code style

apache · Sep 21, 2023 · 23f48ca · 23f48ca
1 parent 601447b
commit 23f48ca
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/hugegraph-core/src/main/java/org/apache/hugegraph/traversal/algorithm/HugeTraverser.java b/hugegraph-core/src/main/java/org/apache/hugegraph/traversal/algorithm/HugeTraverser.java
@@ -1028,8 +1028,8 @@ public class EdgesIterator implements Iterator<Iterator<Edge>>, Closeable {
         public EdgesIterator(EdgesQueryIterator queries) {
             List<Iterator<Edge>> iteratorList = new ArrayList<>();
             while (queries.hasNext()) {
-                iteratorList.add(
-                        graph().edges(queries.next()));
+                Iterator<Edge> edges = graph.edges(queries.next());
+                iteratorList.add(edges);
             }
             this.currentIter = iteratorList.iterator();
         }

diff --git a/hugegraph-core/src/main/java/org/apache/hugegraph/traversal/algorithm/OltpTraverser.java b/hugegraph-core/src/main/java/org/apache/hugegraph/traversal/algorithm/OltpTraverser.java
@@ -285,17 +285,17 @@ public static class ConcurrentVerticesConsumer implements Consumer<EdgeId> {
         private final Set<Id> excluded;
         private final Set<Id> neighbors;
         private final long limit;
+        private final AtomicInteger count;
 
         public ConcurrentVerticesConsumer(Id sourceV, Set<Id> excluded, long limit,
                                           Set<Id> neighbors) {
             this.sourceV = sourceV;
             this.excluded = excluded;
             this.limit = limit;
             this.neighbors = neighbors;
+            this.count = new AtomicInteger(0);
         }
 
-        private final AtomicInteger count = new AtomicInteger(0);
-
         @Override
         public void accept(EdgeId edgeId) {
             if (this.limit != NO_LIMIT && count.get() >= this.limit) {

diff --git a/hugegraph-core/src/main/java/org/apache/hugegraph/util/Consumers.java b/hugegraph-core/src/main/java/org/apache/hugegraph/util/Consumers.java
@@ -208,7 +208,7 @@ public void provide(V v) throws Throwable {
             try {
                 this.queue.put(v);
             } catch (InterruptedException e) {
-                LOG.warn("Interrupted while enqueue", e);
+                LOG.warn("Interrupt while queuing QUEUE_END", e);
             }
         }
     }