heap.Push concurrently
Vladimir Bauer
3 years ago
| 337 | 337 | s.pool = append(s.pool, b) |
| 338 | 338 | } |
| 339 | 339 | |
| 340 | for _, b := range pool { | |
| 341 | heap.Push(&s.bHeap, b) | |
| 342 | } | |
| 340 | wg.Add(1) | |
| 341 | go func() { | |
| 342 | for _, b := range s.pool { | |
| 343 | heap.Push(&s.bHeap, b) | |
| 344 | } | |
| 345 | wg.Done() | |
| 346 | }() | |
| 343 | 347 | |
| 344 | 348 | readRows := len(s.rows) |
| 345 | 349 | for i := readRows - 1; i >= 0; i-- { |