处理关闭中的 BFile 们
()
| 353 | |
| 354 | // 处理关闭中的 BFile 们 |
| 355 | func (this *FS) processClosingBFiles() { |
| 356 | if this.isClosed { |
| 357 | return |
| 358 | } |
| 359 | |
| 360 | var bFile = <-this.closingBChan |
| 361 | if bFile == nil { |
| 362 | return |
| 363 | } |
| 364 | |
| 365 | _ = bFile.Close() |
| 366 | |
| 367 | this.mu.Lock() |
| 368 | delete(this.closingBMap, bFile.Filename()) |
| 369 | this.mu.Unlock() |
| 370 | } |
| 371 | |
| 372 | // 弹出超出BFile数量限制的BFile |
| 373 | func (this *FS) shiftOpenFiles() { |