# | Line 174 | Line 174 | public abstract class BinaryAsyncAction | |
---|---|---|
174 | break; | |
175 | try { | |
176 | p.onComplete(a, s); | |
177 | < | } catch(Throwable rex) { |
177 | > | } catch (Throwable rex) { |
178 | p.completeExceptionally(rex); | |
179 | return; | |
180 | } | |
# | Line 251 | Line 251 | public abstract class BinaryAsyncAction | |
251 | * @param update the new value | |
252 | * @return true if successful | |
253 | */ | |
254 | < | protected final boolean compareAndSetControlState(int expect, |
254 | > | protected final boolean compareAndSetControlState(int expect, |
255 | int update) { | |
256 | return controlStateUpdater.compareAndSet(this, expect, update); | |
257 | } |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |