|
@@ -11,7 +11,7 @@ import java.time.LocalDateTime;
|
|
|
import java.time.ZoneId;
|
|
|
import java.util.Date;
|
|
|
import java.util.List;
|
|
|
-import java.util.concurrent.*;
|
|
|
+import java.util.concurrent.CountDownLatch;
|
|
|
|
|
|
/**
|
|
|
* 定时任务调度测试
|
|
@@ -33,8 +33,8 @@ public class DataTask {
|
|
|
public void metrics() {
|
|
|
Date date = new Date();
|
|
|
objService.selectBizObjList(new BizObj()).forEach(obj -> {
|
|
|
- metricsService.pinpointMetricsValue(obj.getObjId(),date);
|
|
|
- metricsService.prometheusMetricsValue(obj.getObjId(),date);
|
|
|
+ metricsService.pinpointMetricsValue(obj.getObjId(), date);
|
|
|
+ metricsService.prometheusMetricsValue(obj.getObjId(), date);
|
|
|
});
|
|
|
}
|
|
|
|
|
@@ -59,29 +59,36 @@ public class DataTask {
|
|
|
* 模拟一次数据
|
|
|
*/
|
|
|
public void imitateOne() {
|
|
|
- try {
|
|
|
- ExecutorService threadPool = new ThreadPoolExecutor(
|
|
|
- 10,
|
|
|
- 20,
|
|
|
- 3,
|
|
|
- TimeUnit.SECONDS,
|
|
|
- new LinkedBlockingDeque<>(3),
|
|
|
- Executors.defaultThreadFactory(),
|
|
|
- new ThreadPoolExecutor.DiscardOldestPolicy());
|
|
|
- LocalDateTime ed = LocalDateTime.now();
|
|
|
- Date date = Date.from(ed.atZone(ZoneId.systemDefault()).toInstant());
|
|
|
- List<BizObj> list = objService.selectBizObjList(new BizObj());
|
|
|
- CountDownLatch latch = new CountDownLatch(list.size());
|
|
|
- list.forEach(obj -> threadPool.submit(() -> {
|
|
|
- metricsService.imitate(obj.getObjId(), date);
|
|
|
- latch.countDown();
|
|
|
- }));
|
|
|
- // Wait for all threads to finish
|
|
|
- latch.await();
|
|
|
- threadPool.shutdown();
|
|
|
- } catch (InterruptedException e) {
|
|
|
- throw new RuntimeException(e);
|
|
|
- }
|
|
|
+ LocalDateTime ed = LocalDateTime.now();
|
|
|
+ Date date = Date.from(ed.atZone(ZoneId.systemDefault()).toInstant());
|
|
|
+ List<BizObj> list = objService.selectBizObjList(new BizObj());
|
|
|
+ list.forEach(obj -> {
|
|
|
+ metricsService.imitate(obj.getObjId(), date);
|
|
|
+ });
|
|
|
+ // Wait for all threads to finish
|
|
|
+// try {
|
|
|
+// ExecutorService threadPool = new ThreadPoolExecutor(
|
|
|
+// 10,
|
|
|
+// 20,
|
|
|
+// 3,
|
|
|
+// TimeUnit.SECONDS,
|
|
|
+// new LinkedBlockingDeque<>(3),
|
|
|
+// Executors.defaultThreadFactory(),
|
|
|
+// new ThreadPoolExecutor.DiscardOldestPolicy());
|
|
|
+// LocalDateTime ed = LocalDateTime.now();
|
|
|
+// Date date = Date.from(ed.atZone(ZoneId.systemDefault()).toInstant());
|
|
|
+// List<BizObj> list = objService.selectBizObjList(new BizObj());
|
|
|
+// CountDownLatch latch = new CountDownLatch(list.size());
|
|
|
+// list.forEach(obj -> threadPool.submit(() -> {
|
|
|
+// metricsService.imitate(obj.getObjId(), date);
|
|
|
+// latch.countDown();
|
|
|
+// }));
|
|
|
+// // Wait for all threads to finish
|
|
|
+// latch.await();
|
|
|
+// threadPool.shutdown();
|
|
|
+// } catch (InterruptedException e) {
|
|
|
+// throw new RuntimeException(e);
|
|
|
+// }
|
|
|
}
|
|
|
|
|
|
}
|