private SourceData readFromQueue() {
        SourceData sourceData = null;
        try {
            sourceData = queue.poll(WAIT_TIMEOUT_MS, TimeUnit.MILLISECONDS);
        } catch (InterruptedException e) {
            LOGGER.warn("poll {} data get interrupted.", instanceId);
        }
        if (sourceData == null) {
            LOGGER.debug("Read from source queue null {}", inlongGroupId);
            return null;
        }
        LOGGER.debug("Read from source queue {} {}", new String(sourceData.getData()), inlongGroupId);
        MemoryManager.getInstance().release(AGENT_GLOBAL_READER_QUEUE_PERMIT, sourceData.getData().length);
        return sourceData;
    }
Returns the name of the thread, used to identify different data sources

@return source data list
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/file/AbstractSource.java