# | 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 |