修改一些注释
This commit is contained in:
parent
3c3ea56711
commit
3537aaa7e7
@ -33,7 +33,6 @@ public class GnssSingleBufferServiceImpl implements GnssSingleBufferService {
|
|||||||
buffer.add(data);
|
buffer.add(data);
|
||||||
if (buffer.size() >= BUFFER_SIZE) {
|
if (buffer.size() >= BUFFER_SIZE) {
|
||||||
// 溢出时直接保存
|
// 溢出时直接保存
|
||||||
// 此处暂定,但很有必要引入一个线程来保存,避免阻塞主线程
|
|
||||||
flush();
|
flush();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -50,9 +49,8 @@ public class GnssSingleBufferServiceImpl implements GnssSingleBufferService {
|
|||||||
List<GnssSingleData> batchList = new ArrayList<>(buffer);
|
List<GnssSingleData> batchList = new ArrayList<>(buffer);
|
||||||
buffer.clear();
|
buffer.clear();
|
||||||
|
|
||||||
// saveBatch 会导致同步阻塞操作
|
// 数据库操作异步执行,不阻塞主线程
|
||||||
// 数据库操作异步执行,不能阻塞 addData 方法
|
ThreadManager.getSingleThreadPool("gnss-single-save").submit(() -> {
|
||||||
ThreadManager.getSingleThreadPool("gnss-data-save").submit(() -> {
|
|
||||||
try {
|
try {
|
||||||
saveBatch(batchList);
|
saveBatch(batchList);
|
||||||
logger.debug("批量插入{}条数据成功", batchList.size());
|
logger.debug("批量插入{}条数据成功", batchList.size());
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user