360
}
361
362
>
func (s *SliceImpl) SelectTasks(readerID int64, batchSize int) ([]Executable, error) {
slice.go
363
>
s.stateSanityCheck()
364
>
365
>
if len(s.iterators) == 0 {
366
return []Executable{}, nil
367
}
368
370
>
s.monitor.SetSlicePendingTaskCount(s, len(s.pendingExecutables))
371
>
}()
372
373
>
executables := make([]Executable, 0, batchSize)
slice.go
374
>
for len(executables) < batchSize && len(s.iterators) != 0 {
375
>
if s.iterators[0].HasNext() {
376
task, err := s.iterators[0].Next()
377
if err != nil {