Skip to content

Commit

Permalink
switch reconnection to simdExecutor
Browse files Browse the repository at this point in the history
  • Loading branch information
jbellis committed Feb 8, 2024
1 parent 3411a0d commit a0b4881
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -243,7 +243,7 @@ private void reconnectOrphanedNodes() {
// reconnect unreachable nodes
var nReconnected = new AtomicInteger();
var connectionTargets = ConcurrentHashMap.<Integer>newKeySet();
parallelExecutor.submit(() -> IntStream.range(0, graph.getIdUpperBound()).parallel().forEach(node -> {
simdExecutor.submit(() -> IntStream.range(0, graph.getIdUpperBound()).parallel().forEach(node -> {
if (connectedNodes.get(node) || !graph.containsNode(node)) {
return;
}
Expand Down

0 comments on commit a0b4881

Please sign in to comment.