hasUpdatedFinalCache 检查是否已经更新过指定的最终结果缓存
(updateKey string)
| 1117 | |
| 1118 | // hasUpdatedFinalCache 检查是否已经更新过指定的最终结果缓存 |
| 1119 | func (p *BaseAsyncPlugin) hasUpdatedFinalCache(updateKey string) bool { |
| 1120 | p.finalUpdateMutex.RLock() |
| 1121 | defer p.finalUpdateMutex.RUnlock() |
| 1122 | return p.finalUpdateTracker[updateKey] |
| 1123 | } |
| 1124 | |
| 1125 | // markFinalCacheUpdated 标记已更新指定的最终结果缓存 |
| 1126 | func (p *BaseAsyncPlugin) markFinalCacheUpdated(updateKey string) { |
no outgoing calls
no test coverage detected