Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-28 13:19:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

avoided double check locking bugs

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@520937 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
James Strachan 2007-03-21 16:19:26 +00:00
parent a2aed3d732
commit 2a3f9e38ea
1 changed files with 5 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
activemq-core/src/main/java/org/apache/activemq/RedeliveryPolicy.java
View File

@ -97,15 +97,12 @@ public class RedeliveryPolicy implements Cloneable, Serializable {
}
if (useCollisionAvoidance) {
if (randomNumberGenerator == null) {
initRandomNumberGenerator();
}
/*
/*
* First random determines +/-, second random determines how far to
* go in that direction. -cgs
*/
double variance = (randomNumberGenerator.nextBoolean() ? collisionAvoidanceFactor : -collisionAvoidanceFactor) * randomNumberGenerator.nextDouble();
Random random = getRandomNumberGenerator();
double variance = (random.nextBoolean() ? collisionAvoidanceFactor : -collisionAvoidanceFactor) * random.nextDouble();
redeliveryDelay += redeliveryDelay * variance;
}
@ -128,10 +125,11 @@ public class RedeliveryPolicy implements Cloneable, Serializable {
this.useExponentialBackOff = useExponentialBackOff;
}
protected static synchronized void initRandomNumberGenerator() {
protected static synchronized Random getRandomNumberGenerator() {
if (randomNumberGenerator == null) {
randomNumberGenerator = new Random();
}
return randomNumberGenerator;
}
}