diff --git a/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/service/GnssSingleBufferServiceImpl.java b/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/service/GnssSingleBufferServiceImpl.java index e10654a7..44b7295d 100644 --- a/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/service/GnssSingleBufferServiceImpl.java +++ b/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/service/GnssSingleBufferServiceImpl.java @@ -33,7 +33,6 @@ public class GnssSingleBufferServiceImpl implements GnssSingleBufferService { buffer.add(data); if (buffer.size() >= BUFFER_SIZE) { // 溢出时直接保存 - // 此处暂定,但很有必要引入一个线程来保存,避免阻塞主线程 flush(); } } @@ -50,9 +49,8 @@ public class GnssSingleBufferServiceImpl implements GnssSingleBufferService { List batchList = new ArrayList<>(buffer); buffer.clear(); - // saveBatch 会导致同步阻塞操作 - // 数据库操作异步执行,不能阻塞 addData 方法 - ThreadManager.getSingleThreadPool("gnss-data-save").submit(() -> { + // 数据库操作异步执行,不阻塞主线程 + ThreadManager.getSingleThreadPool("gnss-single-save").submit(() -> { try { saveBatch(batchList); logger.debug("批量插入{}条数据成功", batchList.size());