ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/jsr166e/LongMaxUpdater.java
(Generate patch)

Comparing jsr166/src/jsr166e/LongMaxUpdater.java (file contents):
Revision 1.6 by jsr166, Sun Jan 6 18:50:00 2013 UTC vs.
Revision 1.11 by jsr166, Mon May 5 20:20:15 2014 UTC

# Line 5 | Line 5
5   */
6  
7   package jsr166e;
8 +
9   import java.io.IOException;
9 – import java.io.Serializable;
10   import java.io.ObjectInputStream;
11   import java.io.ObjectOutputStream;
12 + import java.io.Serializable;
13  
14   /**
15   * One or more variables that together maintain a running {@code long}
# Line 51 | Line 52 | public class LongMaxUpdater extends Stri
52       * @param x the value to update
53       */
54      public void update(long x) {
55 <        Cell[] as; long b, v; HashCode hc; Cell a; int n;
55 >        Cell[] as; long b, v; int[] hc; Cell a; int n;
56          if ((as = cells) != null ||
57              (b = base) < x && !casBase(b, x)) {
58              boolean uncontended = true;
59 <            int h = (hc = threadHashCode.get()).code;
60 <            if (as == null || (n = as.length) < 1 ||
61 <                (a = as[(n - 1) & h]) == null ||
59 >            if ((hc = threadHashCode.get()) == null ||
60 >                as == null || (n = as.length) < 1 ||
61 >                (a = as[(n - 1) & hc[0]]) == null ||
62                  ((v = a.value) < x && !(uncontended = a.cas(v, x))))
63                  retryUpdate(x, hc, uncontended);
64          }
# Line 65 | Line 66 | public class LongMaxUpdater extends Stri
66  
67      /**
68       * Returns the current maximum.  The returned value is
69 <     * <em>NOT</em> an atomic snapshot: invocation in the absence of
69 >     * <em>NOT</em> an atomic snapshot; invocation in the absence of
70       * concurrent updates returns an accurate result, but concurrent
71       * updates that occur while the value is being calculated might
72       * not be incorporated.
# Line 169 | Line 170 | public class LongMaxUpdater extends Stri
170          return (double)max();
171      }
172  
173 <    private void writeObject(java.io.ObjectOutputStream s)
173 <        throws java.io.IOException {
173 >    private void writeObject(ObjectOutputStream s) throws IOException {
174          s.defaultWriteObject();
175          s.writeLong(max());
176      }
177  
178      private void readObject(ObjectInputStream s)
179 <        throws IOException, ClassNotFoundException {
179 >            throws IOException, ClassNotFoundException {
180          s.defaultReadObject();
181          busy = 0;
182          cells = null;

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines