关于deleteExpiredFile函数的一个问题

消息堆积，并且立即执行磁盘速率阈值（例如0.85或0.90）来删除文件。这种情况可能会导致未使用的消息被删除和消息丢失。

代码如下：

 `private void deleteExpiredFiles() {
    int deleteCount = 0;

    long fileReservedTime = DefaultMessageStore.this.getMessageStoreConfig().getFileReservedTime();
    int deletePhysicFilesInterval = DefaultMessageStore.this.getMessageStoreConfig().getDeleteCommitLogFilesInterval();
    int destroyMapedFileIntervalForcibly = DefaultMessageStore.this.getMessageStoreConfig().getDestroyMapedFileIntervalForcibly();

    boolean timeup = this.isTimeToDelete();

    // core code
    boolean spacefull = this.isSpaceToDelete();

    boolean manualDelete = this.manualDeleteFileSeveralTimes > 0;


    if (timeup || spacefull || manualDelete) {
        if (manualDelete)
            this.manualDeleteFileSeveralTimes--;

        // core code
        boolean cleanAtOnce = DefaultMessageStore.this.getMessageStoreConfig().isCleanFileForciblyEnable() && this.cleanImmediately;

        log.info("begin to delete before {} hours file. timeup: {} spacefull: {} manualDeleteFileSeveralTimes: {} cleanAtOnce: {}",
                fileReservedTime,
                timeup,
                spacefull,
                manualDeleteFileSeveralTimes,
                cleanAtOnce);

        fileReservedTime *= 60 * 60 * 1000;

        deleteCount = DefaultMessageStore.this.commitLog.deleteExpiredFile(
                fileReservedTime,
                deletePhysicFilesInterval,
                destroyMapedFileIntervalForcibly,
                cleanAtOnce);

        if (deleteCount > 0) {
        } else if (spacefull) {
            log.warn("disk space will be full soon, but delete file failed.");
        }
    }
}`

原提问者GitHub用户gentryhuang