Класс LockSupport

public class LockSupport
extends Object

Базовые примитивы блокировки потоков для создания блокировок и других классов синхронизации.

Этот класс ассоциирует с каждым использующим его потоком разрешение (в смысле класса Semaphore). Вызов park вернётся немедленно, если разрешение доступно, потребляя его в процессе; в противном случае он может заблокироваться. Вызов unpark делает разрешение доступным, если оно ещё не было доступно. (В отличие от семафоров, разрешения не накапливаются. Их может быть не более одного.) Надёжное использование требует использования переменных volatile (или атомарных) для управления тем, когда следует останавливать или возобновлять поток. Порядок вызовов этих методов сохраняется относительно доступа к volatile переменным, но не обязательно к не-volatile переменным.

Методы park и unpark обеспечивают эффективный способ блокирования и разблокирования потоков, не сталкиваясь с проблемами, которые делают устаревшие методы Thread.suspend и Thread.resume непригодными для таких целей: гонки между одним потоком, вызывающим park, и другим потоком, пытающимся unpark его, сохранят жизнеспособность из-за разрешения. Кроме того, park вернётся, если поток вызывающего был прерван, и поддерживаются версии с таймаутом. Метод park также может вернуться в любое другое время, без "причины", поэтому, как правило, его необходимо вызывать внутри цикла, который проверяет условия после возвращения. В этом смысле park служит оптимизацией "зацикливания", которая не тратит так много времени на вращение, но должна быть совмещена с unpark, чтобы быть эффективной.

Все три формы park также поддерживают параметр объекта blocker. Этот объект записывается, пока поток заблокирован, чтобы позволить инструментам мониторинга и диагностики определить причины блокировки потоков. (Эти инструменты могут получить доступ к блокировщикам, используя метод getBlocker(Thread).) Настоятельно рекомендуется использовать эти формы вместо исходных форм без этого параметра. Нормальный аргумент для предоставления в качестве blocker в реализации блокировки — this.

Эти методы предназначены для использования в качестве инструментов для создания утилит синхронизации более высокого уровня и сами по себе не пригодны для большинства приложений управления конкурентностью. Метод park предназначен для использования только в конструкциях вида:

while (!canProceed()) {
   // ensure request to unpark is visible to other threads
   ...
   LockSupport.park(this);
 }

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

Пример использования. Вот набросок класса блокировки FIFO, не являющегося реентерабельным:

class FIFOMutex {
   private final AtomicBoolean locked = new AtomicBoolean(false);
   private final Queue<Thread> waiters
     = new ConcurrentLinkedQueue<>();

   public void lock() {
     boolean wasInterrupted = false;
     // publish current thread for unparkers
     waiters.add(Thread.currentThread());

     // Block while not first in queue or cannot acquire lock
     while (waiters.peek() != Thread.currentThread() ||
            !locked.compareAndSet(false, true)) {
       LockSupport.park(this);
       // ignore interrupts while waiting
       if (Thread.interrupted())
         wasInterrupted = true;
     }

     waiters.remove();
     // ensure correct interrupt status on return
     if (wasInterrupted)
       Thread.currentThread().interrupt();
   }

   public void unlock() {
     locked.set(false);
     LockSupport.unpark(waiters.peek());
   }

   static {
     // Reduce the risk of "lost unpark" due to classloading
     Class<?> ensureLoaded = LockSupport.class;
   }
 }