We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Describe the bug nacos-server: 1.4.3 com.alibaba.nacos.naming.consistency.ephemeral.distro.DistroConsistencyServiceImpl
@Override public void listen(String key, RecordListener listener) throws NacosException { if (!listeners.containsKey(key)) { listeners.put(key, new ConcurrentLinkedQueue<>()); } if (listeners.get(key).contains(listener)) { return; } listeners.get(key).add(listener); // 并发下可能重复 } @Override public void unListen(String key, RecordListener listener) throws NacosException { if (!listeners.containsKey(key)) { return; } for (RecordListener recordListener : listeners.get(key)) { // 并发下可能NPE if (recordListener.equals(listener)) { listeners.get(key).remove(listener); break; } } }
The text was updated successfully, but these errors were encountered:
[ISSUE alibaba#8434] enhance DistroConsistencyServiceImpl listen/unLi…
4801e10
…sten method in concurrent condition
[ISSUE #8434] enhance DistroConsistencyServiceImpl listen/unListen me…
b05f471
…thod in concurrent condition (#8435)
No branches or pull requests
Describe the bug
nacos-server: 1.4.3
com.alibaba.nacos.naming.consistency.ephemeral.distro.DistroConsistencyServiceImpl
The text was updated successfully, but these errors were encountered: