opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-01 15:47:01 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #7941] add override annotation (#7959)

Browse Source 
* increase missing annotation

* Revert "increase missing annotation"

This reverts commit c1f3cef51d.

* increase missing annotation
This commit is contained in:
hqbfz
2024-06-13 10:28:02 +08:00
committed by GitHub
parent 107a8118e5
commit 6b59155661
2 changed files with 22 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
test/src/main/java/org/apache/rocketmq/test/util/data/collect/impl/ListDataCollectorImpl.java
+11
View File
@@ -39,19 +39,23 @@ public class ListDataCollectorImpl implements DataCollector {
}
}
@Override
public Collection<Object> getAllData() {
return datas;
}
@Override
public synchronized void resetData() {
datas.clear();
unlockIncrement();
}
@Override
public long getDataSizeWithoutDuplicate() {
return getAllDataWithoutDuplicate().size();
}
@Override
public synchronized void addData(Object data) {
if (lock) {
return;
@@ -59,18 +63,22 @@ public class ListDataCollectorImpl implements DataCollector {
datas.add(data);
}
@Override
public long getDataSize() {
return datas.size();
}
@Override
public boolean isRepeatedData(Object data) {
return Collections.frequency(datas, data) == 1;
}
@Override
public synchronized Collection<Object> getAllDataWithoutDuplicate() {
return new HashSet<Object>(datas);
}
@Override
public int getRepeatedTimeForData(Object data) {
int res = 0;
for (Object obj : datas) {
@@ -81,14 +89,17 @@ public class ListDataCollectorImpl implements DataCollector {
return res;
}
@Override
public synchronized void removeData(Object data) {
datas.remove(data);
}
@Override
public void lockIncrement() {
lock = true;
}
@Override
public void unlockIncrement() {
lock = false;
}
test/src/main/java/org/apache/rocketmq/test/util/data/collect/impl/MapDataCollectorImpl.java
+11
View File
@@ -41,6 +41,7 @@ public class MapDataCollectorImpl implements DataCollector {
}
}
@Override
public synchronized void addData(Object data) {
if (lock) {
return;
@@ -52,6 +53,7 @@ public class MapDataCollectorImpl implements DataCollector {
}
}
@Override
public Collection<Object> getAllData() {
List<Object> lst = new ArrayList<Object>();
for (Entry<Object, AtomicInteger> entry : datas.entrySet()) {
@@ -62,15 +64,18 @@ public class MapDataCollectorImpl implements DataCollector {
return lst;
}
@Override
public long getDataSizeWithoutDuplicate() {
return datas.keySet().size();
}
@Override
public void resetData() {
datas.clear();
unlockIncrement();
}
@Override
public long getDataSize() {
long sum = 0;
for (AtomicInteger count : datas.values()) {
@@ -79,6 +84,7 @@ public class MapDataCollectorImpl implements DataCollector {
return sum;
}
@Override
public boolean isRepeatedData(Object data) {
if (datas.containsKey(data)) {
return datas.get(data).get() == 1;
@@ -86,10 +92,12 @@ public class MapDataCollectorImpl implements DataCollector {
return false;
}
@Override
public Collection<Object> getAllDataWithoutDuplicate() {
return datas.keySet();
}
@Override
public int getRepeatedTimeForData(Object data) {
if (datas.containsKey(data)) {
return datas.get(data).intValue();
@@ -97,14 +105,17 @@ public class MapDataCollectorImpl implements DataCollector {
return 0;
}
@Override
public void removeData(Object data) {
datas.remove(data);
}
@Override
public void lockIncrement() {
lock = true;
}
@Override
public void unlockIncrement() {
lock = false;
}