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

寻找报错

master
Cui YongXing 2024-09-06 11:46:11 +08:00
parent 97a181aff3
commit 0def068b03
3 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
cloud-task-remote/src/main/java/com/muyu/remote/feign/DatasourceFeign.java
View File

@ -32,6 +32,8 @@ public interface DatasourceFeign {
public Result addProduct(@RequestParam("basicId") Long basicId, public Result addProduct(@RequestParam("basicId") Long basicId,
@RequestParam("tableId") Long tableId, @RequestParam("tableId") Long tableId,
@RequestBody List<List<DataValue>> listList); @RequestBody List<List<DataValue>> listList);
@PostMapping("/product/addProduct") @PostMapping("/product/addProduct")
public Result addProduct(@RequestParam("basicId") Long basicId, public Result addProduct(@RequestParam("basicId") Long basicId,
@RequestParam("tableId") Long tableId, @RequestParam("tableId") Long tableId,

2
cloud-task-server/src/main/java/com/muyu/task/server/service/impl/TaskInfoServiceImpl.java
View File

@ -42,7 +42,7 @@ import static com.muyu.task.server.thread.OptimizedPrioritizedThreadPool.*;
@Service @Service
public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> implements TaskInfoService { public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> implements TaskInfoService {
private final Integer PAGE_SIZE = 5000; private final Integer PAGE_SIZE = 10000;
@Resource @Resource
private TaskInfoMapper taskInfoMapper; private TaskInfoMapper taskInfoMapper;

8
cloud-task-server/src/main/java/com/muyu/task/server/thread/OptimizedPrioritizedThreadPool.java
View File

@ -11,10 +11,10 @@ public class OptimizedPrioritizedThreadPool {
private static final Semaphore lowPrioritySemaphore; private static final Semaphore lowPrioritySemaphore;
private static final Semaphore emergencySemaphore; private static final Semaphore emergencySemaphore;
private static final int totalThreads =40; // 固定线程池大小 private static final int totalThreads =50; // 固定线程池大小
private static final int defaultHighThreads = 22; private static final int defaultHighThreads = 26;
private static final int defaultMediumThreads = 12; private static final int defaultMediumThreads = 15;
private static final int defaultLowThreads = 6; private static final int defaultLowThreads = 9;
private static final int emergencyThreads = 21; private static final int emergencyThreads = 21;
private static final int emergencyHighThreads = 10; private static final int emergencyHighThreads = 10;