54
// Add will try to batch input task with the last task in the queue. Since most likely incoming task
55
// are ordered by task ID, we only try to batch incoming task with last task in the queue.
56
>
func (q *SequentialBatchableTaskQueue) Add(task TrackableExecutableTask) {
sequential_batch_queue.go
57
>
q.Lock()
58
>
defer q.Unlock()
59
>
60
>
if q.lastTask != nil && q.lastTask.AddTask(task) {
61
return
62
}
63
65
>
q.taskQueue.Add(incomingTask)
66
>
q.updateLastTask(incomingTask)
67
}
68
69
>
func (q *SequentialBatchableTaskQueue) Remove() (task TrackableExecutableTask) {
sequential_batch_queue.go
70
>
q.Lock()
71
>
defer q.Unlock()
72
>
taskToRemove := q.taskQueue.Remove()
73
>
if taskToRemove == q.lastTask {
74
>
q.lastTask = nil
75
>
}
76
>
return taskToRemove
77
}
78