wangli/msg-center-plat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

REQ-3828: fix concurrency issue

Browse Source
This commit is contained in:
yanglin 2024-12-26 09:38:15 +08:00
parent f75b5cca1a
commit cafef633a6
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
inside-notices/src/main/java/cn/axzo/msg/center/message/service/card/domain/CardSendModel.java
View File

@ -13,6 +13,7 @@ import lombok.Setter;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Collection; import java.util.Collection;
import java.util.Collections;
import java.util.HashMap; import java.util.HashMap;
import java.util.List; import java.util.List;
@ -26,7 +27,7 @@ public class CardSendModel {
private final CardRequestContext<CardSendRequest> requestContext; private final CardRequestContext<CardSendRequest> requestContext;
private final CardTemplate cardTemplate; private final CardTemplate cardTemplate;
private final List<Card> cards = new ArrayList<>(); private final List<Card> cards = Collections.synchronizedList(new ArrayList<>());
private GeneralMessagePushVO cardContent; private GeneralMessagePushVO cardContent;

1
inside-notices/src/main/java/cn/axzo/msg/center/utils/RecordCursor.java
View File

@ -36,6 +36,7 @@ public class RecordCursor<T> implements Iterable<List<T>> {
return new Iterator<List<T>>() { return new Iterator<List<T>>() {
long maxId = 0; long maxId = 0;
// single thread producer
volatile List<T> batch; volatile List<T> batch;
Boolean batchConsumed; Boolean batchConsumed;