@Override
                    public MessageStore call() throws Exception {
                        MessageStore msgStore = null;
                        try {
                            msgStore = new MessageStore(messageStoreManager,
                                    topicMetadata, storeId, tubeConfig, maxMsgTransferSize);
                            ConcurrentHashMap<Integer, MessageStore> map =
                                    dataStores.get(msgStore.getTopic());
                            if (map == null) {
                                map = new ConcurrentHashMap<>();
                                ConcurrentHashMap<Integer, MessageStore> oldmap =
                                        dataStores.putIfAbsent(msgStore.getTopic(), map);
                                if (oldmap != null) {
                                    map = oldmap;
                                }
                            }
                            MessageStore oldMsgStore = map.putIfAbsent(msgStore.getStoreId(), msgStore);
                            if (oldMsgStore != null) {
                                try {
                                    msgStore.close();
                                    logger.info(new StringBuilder(512)
                                            .append("[Store Manager] Close duplicated messageStore ")
                                            .append(msgStore.getStoreKey()).toString());
                                } catch (Throwable e2) {
                                    //
                                    logger.info("[Store Manager] Close duplicated messageStore failure", e2);
                                }
                            }
                        } catch (Throwable e2) {
                            errCnt.incrementAndGet();
                            logger.error(new StringBuilder(512).append("[Store Manager] Loaded ")
                                    .append(subDir.getAbsolutePath())
                                    .append("message store failure:").toString(), e2);
                        } finally {
                            finishCnt.incrementAndGet();
                        }
                        return null;
                    }
Load stores sequential.

@param tubeConfig             the broker's configure
@throws IOException           the exception during processing
@throws InterruptedException  the exception during processing
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/msgstore/MessageStoreManager.java