// DisableHandleSubtasks disables the functionality of start/watch/handle subtasks.
DisableHandleSubtasks disables the functionality of start/watch/handle subtasks.
// DisableHandleSubtasks disables the functionality of start / watch / handle subtasks .
func (w *SourceWorker) DisableHandleSubtasks() {
	w.l.Info("enter DisableHandleSubtasks")
	if !w.subTaskEnabled.CAS(true, false) {
		w.l.Warn("already disabled handling subtasks")
		return
	}
	w.subTaskCancel()
	w.subTaskWg.Wait()
	w.Lock()
	defer w.Unlock()
	w.subTaskHolder.closeAllSubTasks()
	w.l.Info("handling subtask enabled")
}
func ( w * SourceWorker ) DisableHandleSubtasks ( ) { w . l . Info ( " " ) if ! w . subTaskEnabled . CAS ( true , false ) { w . l . Warn ( " " ) return } w . subTaskCancel ( ) w . subTaskWg . Wait ( ) w . Lock ( ) defer w . Unlock ( ) w . subTaskHolder . closeAllSubTasks ( ) w . l . Info ( " " ) }
DisableHandleSubtasks disables the functionality of start/watch/handle subtasks.
DisableHandleSubtasks disables the functionality of start / watch / handle subtasks .
// close all sub tasks