private boolean waitAllFetchRequestHolds(long waitTimeInMills) {
        boolean haveProcessingThread = false;
        long startWaitTime = System.currentTimeMillis();
        do {
            haveProcessingThread =
                    (!this.fetchWorkerStatusMap.isEmpty());
            if (haveProcessingThread) {
                try {
                    Thread.sleep(150);
                } catch (InterruptedException e1) {
                    break;
                }
            }
        } while ((haveProcessingThread)
                && ((System.currentTimeMillis() - startWaitTime) < waitTimeInMills));
        return haveProcessingThread;
    }
Stop fetch worker threads

@param onlySetStatus  Whether to only set the state without stopping the operation
inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/consumer/MessageFetchManager.java