Method SubmitUploadTask

api/service/batch_upload_manager.go:296–305

SubmitUploadTask 提交上传任务

(task *UploadTask)

// SubmitUploadTask 提交上传任务
func (m *BatchUploadManager) SubmitUploadTask(task *UploadTask) error {
	// 获取信号量
	select {
	case m.semaphore <- struct{}{}:
		go m.processUploadTask(task)
		return nil
	default:
		return fmt.Errorf("上传队列已满，请稍后重试")
	}
}

// processUploadTask 处理上传任务
func (m *BatchUploadManager) processUploadTask(task *UploadTask) {