| # | Line 821 | Line 821 | public class LinkedTransferQueue<E> exte | |
|---|---|---|
| 821 | break; | |
| 822 | } | |
| 823 | if (oldpred == pred || // Already saved | |
| 824 | < | (oldpred == null && casCleanMe(null, pred))) |
| 825 | < | break; // Postpone cleaning |
| 824 | > | ((oldpred == null || oldpred.next == s) && |
| 825 | > | casCleanMe(oldpred, pred))) { |
| 826 | > | break; |
| 827 | > | } |
| 828 | } | |
| 829 | } | |
| 830 | } | |
| – | Removed lines |
| + | Added lines |
| < | Changed lines |
| > | Changed lines |