Author: markt
Date: Fri Sep 18 13:41:34 2015
New Revision: 1703849
URL: http://svn.apache.org/viewvc?rev=1703849&view=rev
Log:
More thread-safety
Modified:
tomcat/trunk/java/org/apache/catalina/tribes/membership/MemberImpl.java
Modified:
tomcat/trunk/java/org/apache/catalina/tribes/membership/MemberImpl.java
URL:
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/membership/MemberImpl.java?rev=1703849&r1=1703848&r2=1703849&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/catalina/tribes/membership/MemberImpl.java
(original)
+++ tomcat/trunk/java/org/apache/catalina/tribes/membership/MemberImpl.java Fri
Sep 18 13:41:34 2015
@@ -21,6 +21,7 @@ import java.io.IOException;
import java.io.ObjectInput;
import java.io.ObjectOutput;
import java.util.Arrays;
+import java.util.concurrent.atomic.AtomicInteger;
import org.apache.catalina.tribes.Member;
import org.apache.catalina.tribes.io.XByteBuffer;
@@ -66,7 +67,8 @@ public class MemberImpl implements Membe
/**
* Counter for how many broadcast messages have been sent from this member
*/
- protected int msgCount = 0;
+ protected AtomicInteger msgCount = new AtomicInteger(0);
+
/**
* The number of milliseconds since this member was
* created, is kept track of using the start time
@@ -156,7 +158,7 @@ public class MemberImpl implements Membe
* Increment the message count.
*/
protected void inc() {
- msgCount++;
+ msgCount.incrementAndGet();
}
/**
@@ -458,7 +460,7 @@ public class MemberImpl implements Membe
}
public int getMsgCount() {
- return this.msgCount;
+ return msgCount.get();
}
/**
@@ -587,7 +589,7 @@ public class MemberImpl implements Membe
}
public void setMsgCount(int msgCount) {
- this.msgCount = msgCount;
+ this.msgCount.set(msgCount);
}
public synchronized void setPort(int port) {
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscr...@tomcat.apache.org
For additional commands, e-mail: dev-h...@tomcat.apache.org
