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

寻找报错

master
Cui YongXing 2024-09-05 23:38:14 +08:00
parent 47bfaba772
commit 9cc6bd3249
2 changed files with 3 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -254,11 +254,7 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
submitHighPriorityTask(()->{
getString(pageNum, finalFieName, finalJoint,basicId,newBasicId,tableId,map,num);
});
try {
TimeUnit.MILLISECONDS.sleep(100); // 适当延迟，避免所有任务同时提交
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}
}
if (Weight.centre.getValue().equals(weight)){
@ -312,9 +308,10 @@ public class TaskInfoServiceImpl extends ServiceImpl<TaskInfoMapper, TaskInfo> i
String sqlSelect = " SELECT " + fieName + " FROM " + joint +" limit "+pageNum +","+PAGE_SIZE;
log.info(sqlSelect);
log.info("执行{}查询的方法",sqlSelect);
//log.info("执行{}查询的方法",sqlSelect);
Result<DataValue[][]> tableValueResult = datasourceFeign.findTableValueToArray(basicId, sqlSelect);
DataValue[][] data = tableValueResult.getData();
log.info("执行{}查询的方法结束",sqlSelect);
// if (pageNum==160000){
// for (DataValue[] datum : data) {
// for (DataValue dataValue : datum) {

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

@ -57,9 +57,7 @@ public class OptimizedPrioritizedThreadPool {
emergencySemaphore.acquire();
executor.submit(() -> {
try {
System.out.println("Starting emergency task...");
task.run();
System.out.println("Finished emergency task.");
} finally {
emergencySemaphore.release();
if (remainingTasks.decrementAndGet() == 0) {
@ -69,7 +67,6 @@ public class OptimizedPrioritizedThreadPool {
});
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
System.err.println("Interrupted while waiting to execute emergency task.");
}
}
@ -78,16 +75,13 @@ public class OptimizedPrioritizedThreadPool {
highPrioritySemaphore.acquire();
executor.submit(() -> {
try {
System.out.println("Starting high priority task...");
task.run();
System.out.println("Finished high priority task.");
} finally {
highPrioritySemaphore.release();
}
});
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
System.err.println("Interrupted while waiting to execute high priority task.");
}
}
@ -96,16 +90,13 @@ public class OptimizedPrioritizedThreadPool {
mediumPrioritySemaphore.acquire();
executor.submit(() -> {
try {
System.out.println("Starting medium priority task...");
task.run();
System.out.println("Finished medium priority task.");
} finally {
mediumPrioritySemaphore.release();
}
});
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
System.err.println("Interrupted while waiting to execute medium priority task.");
}
}
@ -114,16 +105,13 @@ public class OptimizedPrioritizedThreadPool {
lowPrioritySemaphore.acquire();
executor.submit(() -> {
try {
System.out.println("Starting low priority task...");
task.run();
System.out.println("Finished low priority task.");
} finally {
lowPrioritySemaphore.release();
}
});
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
System.err.println("Interrupted while waiting to execute low priority task.");
}
}