TreeData
/
cloud-etl-task
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

测试线程池

master
陈思豪 2024-09-08 21:17:52 +08:00
parent a231c29341
commit ff30d1693d
2 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
cloud-task-common/pom.xml
View File

@ -29,6 +29,7 @@
<artifactId>cloud-etl-common</artifactId>
<version>1.0.0</version>
</dependency>
</dependencies>
</project>

10
cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java
View File

@ -7,7 +7,10 @@ import com.muyu.common.core.utils.StringUtils;
import com.muyu.domain.*;
import com.muyu.domain.req.TaskInfoReq;
import com.muyu.mapper.TaskMapper;
import com.muyu.service.*;
import com.muyu.service.TaskInputService;
import com.muyu.service.TaskJoinService;
import com.muyu.service.TaskOutputService;
import com.muyu.service.TaskService;
import com.muyu.task.feign.DataValueClient;
import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired;
@ -16,7 +19,6 @@ import org.springframework.stereotype.Service;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.concurrent.ConcurrentHashMap;
import static com.muyu.task.PriorityThreadPool.*;
@ -346,8 +348,8 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
// }
}
@Autowired
private NodeRuleService nodeRuleService;
// @Autowired
// private NodeRuleService nodeRuleService;
// @Autowired
// private RuleFeign ruleFeign;