add @SuppressWarnings(NonAtomicVolatileUpdate) (apache#5606)

Co-authored-by: 吴晟 Wu Sheng <[email protected]>
mantiswang · Oct 1, 2020 · 1cddb60 · 1cddb60
1 parent 6f99a24
commit 1cddb60
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/...java/org/apache/skywalking/apm/commons/datacarrier/consumer/MultipleChannelsConsumer.java b/...java/org/apache/skywalking/apm/commons/datacarrier/consumer/MultipleChannelsConsumer.java
@@ -30,6 +30,7 @@
 public class MultipleChannelsConsumer extends Thread {
     private volatile boolean running;
     private volatile ArrayList<Group> consumeTargets;
+    @SuppressWarnings("NonAtomicVolatileUpdate")
     private volatile long size;
     private final long consumeCycle;
 

diff --git a/...ava/org/apache/skywalking/apm/commons/datacarrier/partition/SimpleRollingPartitioner.java b/...ava/org/apache/skywalking/apm/commons/datacarrier/partition/SimpleRollingPartitioner.java
@@ -22,6 +22,7 @@
  * use normal int to rolling.
  */
 public class SimpleRollingPartitioner<T> implements IDataPartitioner<T> {
+    @SuppressWarnings("NonAtomicVolatileUpdate")
     private volatile int i = 0;
 
     @Override