Function NewTaskManagerWithMaxRunning

internal/taskmanager/manager.go:78–91

(clientResolver ClientResolver, updateNotify func(), maxRunning int)

}

func NewTaskManagerWithMaxRunning(clientResolver ClientResolver, updateNotify func(), maxRunning int) *TaskManager {
	if maxRunning < 1 {
		maxRunning = defaultMaxRunningTasks
	}

	return &TaskManager{
		queue:          make(map[string][]*Task),
		activeTasks:    make(map[string]*Task),
		clientResolver: clientResolver,
		updateNotify:   updateNotify,
		maxRunning:     maxRunning,
		stopChan:       make(chan struct{}),
	}
}

func taskKey(node string, vmid int) string {
	return fmt.Sprintf("%s/%d", node, vmid)