@Override
    public int size() {
        return keyValMap.size();
    }
ConcurrentHashSet, construct the set collection through ConcurrentHashMap
 to complete the operation management of the concurrent set
inlong-tubemq/tubemq-core/src/main/java/org/apache/inlong/tubemq/corebase/utils/ConcurrentHashSet.java