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

测试线程池

master
陈思豪 2024-09-09 15:05:09 +08:00
parent 5c8e646819
commit 9a154b6379
4 changed files with 15 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
cloud-task-remote/src/main/java/com/muyu/task/feign/DataValueClient.java
View File

@ -2,7 +2,6 @@ package com.muyu.task.feign;
import com.muyu.common.core.domain.Result;
import com.muyu.domain.DataValue;
import com.muyu.task.feign.config.CustomFeignConfig;
import com.muyu.task.feign.factory.DataValueClientFactory;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PostMapping;
@ -19,7 +18,7 @@ import java.util.List;
* @date: 2024/9/4 15:13
*/
//,fallback = TaskFeignFallback.class
@FeignClient(name = "cloud-source",fallbackFactory = DataValueClientFactory.class,configuration = CustomFeignConfig.class )
@FeignClient(name = "cloud-source",fallbackFactory = DataValueClientFactory.class )
public interface DataValueClient {
/**
@ -49,7 +48,7 @@ public interface DataValueClient {
//二维数组查询
@PostMapping("/DataValue/findTableValueToArray")
public DataValue[][] findTableValueToArray(@RequestParam("basicId") Long basicId, @RequestParam("sql") String sql, @RequestParam("one") Long one, @RequestParam("two") Integer two);
public Result<DataValue[][]> findTableValueToArray(@RequestParam("basicId") Long basicId, @RequestParam("sql") String sql, @RequestParam("one") Long one, @RequestParam("two") Integer two);
//添加数据值

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

@ -38,7 +38,7 @@ public class DataValueClientFactory implements FallbackFactory<DataValueClient>
}
@Override
public DataValue[][] findTableValueToArray(Long basicId, String sql, Long one, Integer two) {
public Result<DataValue[][]> findTableValueToArray(Long basicId, String sql, Long one, Integer two) {
return null;
}

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

@ -237,21 +237,21 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
log.info("开始查询数据");
log.info("sql{}", sql);
log.info("数组为{}，，{}", finalFirstArray, two);
DataValue[][] tableValue = dataValueClient.findTableValueToArray(databaseId, sql, finalFirstArray, two);
System.out.println("aaa"+tableValue.length);
System.out.println("aaa"+tableValue.length);
System.out.println("aaa"+tableValue.length);
System.out.println("aaa"+tableValue.length);
log.info("远程调用完毕,调用数量{}", tableValue.length);
for (DataValue[] dataValues : tableValue) {
for (DataValue dataValue : dataValues) {
String key = dataValue.getKey();
Result<DataValue[][]> result = dataValueClient.findTableValueToArray(databaseId, sql, finalFirstArray, two);
DataValue[][] dataValues = result.getData();
System.out.println("aaa"+dataValues.length);
System.out.println("aaa"+dataValues.length);
System.out.println("aaa"+dataValues.length);
log.info("远程调用完毕,调用数量{}", dataValues.length);
for (DataValue[] dataValue : dataValues) {
for (DataValue dataValue1 : dataValue) {
String key = dataValue1.getKey();
String newKey = newAndOldMap.get(key);
dataValue.setKey(newKey);
dataValue1.setKey(newKey);
}
}
Result result = dataValueClient.addProduct(basicId, tableId, tableValue);
log.info("添加结果为{}", result);
Result results = dataValueClient.addProduct(basicId, tableId, dataValues);
log.info("添加结果为{}", results);
log.info("添加到queue里成功");
}

1
cloud-task-server/src/main/java/com/muyu/task/PriorityThreadPool.java
View File

@ -298,7 +298,6 @@ public class PriorityThreadPool {
try {
log.info("开始执行任务");
task.run();
} finally {
log.info("执行任务完毕？？");
lowPrioritySemaphore.release();