I want a list of tasks to submit to the pool, and want the submitted task to complete

Hey <a class="user-mention notranslate" data-hovercard-type="user" data-hovercard-url=

does pond support serial queue? about pond HOT 3 CLOSED

alitto commented on May 15, 2024

does pond support serial queue?

from pond.

Comments (3)

haifenghuang commented on May 15, 2024 1

Thanks a lot! Maybe I'm not express myself clearly. You are right, the example is what I wanted.

from pond.

alitto commented on May 15, 2024

Hey @haifenghuang!
I'm afraid that pattern is not supported by this library.
I guess you could mimic that behavior if you group tasks into other functions that each run a subset of tasks one after the other (sequentially). For the sake of the example, let's say you have the following function, which takes a slice of tasks and returns another one where each element is a group of tasks which run sequentially:

func groupTasks(tasks []func(), groupSize int) (taskGroups []func()) {

	taskCount := len(tasks)
	groupCount := int(math.Ceil(float64(taskCount) / float64(groupSize)))

	var groupStart, groupEnd int

	for i := 0; i < groupCount; i++ {
		groupStart = i * groupSize
		groupEnd = int(math.Min(float64((i+1)*groupSize), float64(taskCount)))
		taskGroup := tasks[groupStart:groupEnd]
		taskGroups = append(taskGroups, func() {
			for _, task := range taskGroup {
				task()
			}
		})
	}

	return
}

Then you could submit these "grouped tasks" to a pool like this:

// Create pool
pool := pond.New(10, 1000)

// Split tasks in groups of up to 3 elements
groupedTasks := groupTasks(tasks, 3)

// Submit grouped tasks to the pool
for _, task := range groupedTasks {
	pool.Submit(task)
}