diff --git a/resolver/src/main/java/io/netty/resolver/AddressResolverGroup.java b/resolver/src/main/java/io/netty/resolver/AddressResolverGroup.java index 89b00dfa04..509475eb3e 100644 --- a/resolver/src/main/java/io/netty/resolver/AddressResolverGroup.java +++ b/resolver/src/main/java/io/netty/resolver/AddressResolverGroup.java @@ -73,7 +73,9 @@ public abstract class AddressResolverGroup implements C executor.terminationFuture().addListener(new FutureListener() { @Override public void operationComplete(Future future) throws Exception { - resolvers.remove(executor); + synchronized (resolvers) { + resolvers.remove(executor); + } newResolver.close(); } });