Method AddTask

internal/task_group/group.go:35–46

payload可为nil

(groupID string, payload any)

// payload可为nil
func (tgc *TaskGroupCoordinator) AddTask(groupID string, payload any) {
	tgc.mu.Lock()
	defer tgc.mu.Unlock()
	state := tgc.groupStates[groupID]
	state.pending++
	tgc.groupStates[groupID] = state
	logrus.Debugf("AddTask:%s ,count=%+v", groupID, state)
	if payload == nil {
		return
	}
	tgc.groupPayloads[groupID] = append(tgc.groupPayloads[groupID], payload)
}

func (tgc *TaskGroupCoordinator) AppendPayload(groupID string, payload any) {
	if payload == nil {