File tree Expand file tree Collapse file tree 1 file changed +0
-11
lines changed
src/main/java/rx/internal/util/unsafe Expand file tree Collapse file tree 1 file changed +0
-11
lines changed Original file line number Diff line number Diff line change @@ -118,20 +118,9 @@ public SpscArrayQueue(final int capacity) {
118118 */
119119 @ Override
120120 public boolean offer (final E e ) {
121- // if (null == e) {
122- // throw new NullPointerException("Null is not a valid element");
123- // }
124121 // local load of field to avoid repeated loads after volatile reads
125122 final E [] lElementBuffer = buffer ;
126123 final long offset = calcElementOffset (producerIndex );
127- // if (producerIndex >= producerLookAhead) {
128- // if (null == lvElement(lElementBuffer, calcElementOffset(producerIndex + lookAheadStep))) {// LoadLoad
129- // producerLookAhead = producerIndex + lookAheadStep;
130- // }
131- // else if (null != lvElement(lElementBuffer, offset)){
132- // return false;
133- // }
134- // }
135124 if (null != lvElement (lElementBuffer , offset )){
136125 return false ;
137126 }
You can’t perform that action at this time.
0 commit comments