# | Line 736 | Line 736 | public class SubmissionPublisher<T> impl | |
---|---|---|
736 | executor.execute(task); | |
737 | break; | |
738 | } catch (RuntimeException | Error ex) { // back out | |
739 | < | do {} while((c = ctl) >= 0 && |
740 | < | (c & ACTIVE) != 0 && |
741 | < | !U.compareAndSwapInt(this, CTL, c, |
742 | < | c & ~ACTIVE)); |
739 | > | do {} while ((c = ctl) >= 0 && |
740 | > | (c & ACTIVE) != 0 && |
741 | > | !U.compareAndSwapInt(this, CTL, c, |
742 | > | c & ~ACTIVE)); |
743 | throw ex; | |
744 | } | |
745 | } |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |