Skip to content

Commit 4535fbf

Browse files
committed
refactor: simplify index management in DefaultShenyuPluginChain
1 parent cdc5929 commit 4535fbf

File tree

1 file changed

+3
-5
lines changed

1 file changed

+3
-5
lines changed

shenyu-web/src/main/java/org/apache/shenyu/web/handler/ShenyuWebHandler.java

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,6 @@
4444
import java.util.Map;
4545
import java.util.Objects;
4646
import java.util.Optional;
47-
import java.util.concurrent.atomic.AtomicInteger;
4847
import java.util.function.Function;
4948
import java.util.stream.Collectors;
5049

@@ -308,7 +307,7 @@ private void onPluginRemoved(final PluginData pluginData) {
308307

309308
private static class DefaultShenyuPluginChain implements ShenyuPluginChain {
310309

311-
private final AtomicInteger index = new AtomicInteger(0);
310+
private int index;
312311

313312
private final List<ShenyuPlugin> plugins;
314313

@@ -330,9 +329,8 @@ private static class DefaultShenyuPluginChain implements ShenyuPluginChain {
330329
@Override
331330
public Mono<Void> execute(final ServerWebExchange exchange) {
332331
return Mono.defer(() -> {
333-
int pos;
334-
while ((pos = index.getAndIncrement()) < plugins.size()) {
335-
ShenyuPlugin plugin = plugins.get(pos);
332+
while (this.index < plugins.size()) {
333+
ShenyuPlugin plugin = plugins.get(this.index++);
336334
if (plugin.skip(exchange)) {
337335
continue;
338336
}

0 commit comments

Comments
 (0)