docs: private void checkCloseChannel(NodeType nodeType, ConcurrentHashMap<String, List<ChannelWrapper>> channelMap) {
          for (Map.Entry<String, List<ChannelWrapper>> entry : channelMap.entrySet()) {
              List<ChannelWrapper> channels = entry.getValue();
              List<ChannelWrapper> removeList = new ArrayList<ChannelWrapper>();
              for (ChannelWrapper channel : channels) {
                  if (channel.isClosed()) {
                      removeList.add(channel);
                      LOGGER.info("close channel={}", channel);
                  }
              }
              channels.removeAll(removeList);
              // 加入到离线列表中
              if (nodeType == NodeType.TASK_TRACKER) {
                  for (ChannelWrapper channelWrapper : removeList) {
                      offlineTaskTrackerMap.put(channelWrapper.getIdentity(), SystemClock.now());
                  }
              }
          }
      }