@Override
        public void run() {
            BlockingQueue<LongPollingClient> namespaceClients = clientsMap.get(namespaceId);
            if (CollectionUtils.isEmpty(namespaceClients)) {
                return;
            }
            if (namespaceClients.size() > httpSyncProperties.getNotifyBatchSize()) {
                List<LongPollingClient> targetClients = new ArrayList<>(namespaceClients.size());
                namespaceClients.drainTo(targetClients);
                List<List<LongPollingClient>> partitionClients = Lists.partition(targetClients, httpSyncProperties.getNotifyBatchSize());
                partitionClients.forEach(item -> scheduler.execute(() -> doRun(item)));
            } else {
                doRun(namespaceClients);
            }
        }
Instantiates a new Data change task.

@param groupKey the group key
shenyu-admin/src/main/java/org/apache/shenyu/admin/listener/http/HttpLongPollingDataChangedListener.java