ConcurrentLinkedQueue код Пояснение

Question

http://www.java2s.com/Open-Source/Java-Open-Source-Library/7-JDK/java/java/util/concurrent/ConcurrentLinkedQueue.java.htm

Выше исходный код ConcurrentLinkedQueue. Я не могу понять одно условие.

Как условие (р == д) придет ниже фрагмент кода из предложения метода

public boolean offer(E e) { 
     checkNotNull(e); 
     final Node<E> newNode = new Node<E>(e); 

     for (Node<E> t = tail, p = t;;) { 
      Node<E> q = p.next; 
      if (q == null) { 
       // p is last node 
       if (p.casNext(null, newNode)) { 
        // Successful CAS is the linearization point 
        // for e to become an element of this queue, 
        // and for newNode to become "live". 
        if (p != t) // hop two nodes at a time 
         casTail(t, newNode); // Failure is OK. 
        return true; 
       } 
       // Lost CAS race to another thread; re-read next 
      } 
      else if (p == q) 
       // We have fallen off list. If tail is unchanged, it 
       // will also be off-list, in which case we need to 
       // jump to head, from which all live nodes are always 
       // reachable. Else the new tail is a better bet. 
       p = (t != (t = tail)) ? t : head; 
      else 
       // Check for tail updates after two hops. 
       p = (p != t && t != (t = tail)) ? t : q; 
     } 
    } 

, а также то, что делает автор в виду под «Мы отвалились список»

Answer 1

ConcurrentLinkedQueue позволяет одновременное изменение внутреннего списка во время прохождения его. Это означает, что узел, на который вы смотрите, мог быть удален одновременно. Чтобы обнаружить такие ситуации, следующий указатель удаляемого узла изменится, чтобы указать на себя. Посмотрите на номер updateHead (L302).

Answer 2

Условие задает вопрос «Является ли текущий узел таким же, как следующий узел?»

Если да, то вы вылезли список

Основной контур шагов (документации в строке.):

1. создать новый узел для предлагаемых данных.
2. Пройдите список, чтобы найти последний узел
3. Вставить новый узел в качестве нового хвоста.

Другие части оператора if обрабатывают проблемы одновременной модификации.

Чтобы лучше понять, что происходит, читайте Node.casTail() и casNext()