一个关于延时消息的load小问题，以及可能的多线程问题 about qmq HOT 4 CLOSED

    //根据消息的延时时间(scheduleTime)，计算该消息应该落在schedule log的哪个分片(segment)
    long baseOffset = resolveSegment(scheduleTime, segmentScale); 
     //如果该分片的偏移比当前正在投递的分片偏移小，则立即添加进内存时间轮
     if (baseOffset < currentBaseOffset) return true; 
      
     //如果该消息正好需要落在当前时间片
     if (baseOffset == currentBaseOffset) {
         //则判断该消息在当前schedule log segment里的偏移是否大于正在加载的最大偏移
         //如果大的话则立即加载到内存时间轮。
         //这里要注意的是，当加载任务决定要加载某个segment的时候，
         //就会立即固定住当时该segment的最大偏移，也就是currentOffset，
         //所以这样就不会将消息重复的加载 
         return currentOffset <= offset; 
     } 

// 这里的loadingCursor.cursor() 是返回的一个新实例的，所以currentCursor只在当前线程可见的，别的线程不会修改它的
WheelLoadCursor.Cursor currentCursor = loadingCursor.cursor();
int currentBaseOffset = currentCursor.getBaseOffset();
long currentOffset = currentCursor.getOffset();