public synchronized boolean createIfAbsent(String poolName, Callable<ConsumerPool> creator) throws Exception {
        if (pools.containsKey(poolName)) {
            return false;
        } else {
            pools.put(poolName, creator.call());
            return true;
        }
    }
Consumer Pool Factory provides global management for all Consumer Pool.
oap-server/server-library/library-datacarrier-queue/src/main/java/org/apache/skywalking/oap/server/library/datacarrier/consumer/ConsumerPoolFactory.java