Класс LockSupport

public class LockSupport
extends Object

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

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

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

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

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

while (!canProceed()) { ... LockSupport.park(this); }

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

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

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

   public void lock() {
     boolean wasInterrupted = false;
     Thread current = Thread.currentThread();
     waiters.add(current);

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

     waiters.remove();
     if (wasInterrupted)          // reassert interrupt status on exit
       current.interrupt();
   }

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

Методы

unpark

public static void unpark(Thread thread)

Освобождает разрешение для указанной нити, если оно ещё не было доступно. Если нить была заблокирована на park, то она будет разблокирована. В противном случае, её следующий вызов park гарантированно не заблокируется. Данная операция гарантированно не окажет никакого эффекта, если указанная нить не была запущена.

Параметры:

thread - нить для разблокировки, или null, в этом случае операция не оказывает никакого эффекта

park

public static void park(Object blocker)

Параметры:

blocker - объект синхронизации, ответственный за приостановку этой нити

С:

1.6

parkNanos

public static void parkNanos(Object blocker,
                             long nanos)

Параметры:

blocker - объект синхронизации, ответственный за приостановку этой нити

nanos - максимальное количество наносекунд ожидания

С:

1.6

parkUntil

public static void parkUntil(Object blocker,
                             long deadline)

Параметры:

blocker - объект синхронизации, ответственный за приостановку этой нити

deadline - абсолютное время, в миллисекундах с начала эпохи, до ожидания

С:

1.6

getBlocker

public static Object getBlocker(Thread t)

Возвращает объект блокировщика, предоставленный последним вызовом метода park, который ещё не разблокирован, или null, если не заблокирован. Возвращаемое значение — это просто моментальный снимок; нить может быть разблокирована или заблокирована на другом объекте блокировщика.

Параметры:

t - нить

Возвращает:

блокировщик

Исключения:

NullPointerException - если аргумент равен null

С:

1.6

park

public static void park()

parkNanos

public static void parkNanos(long nanos)

Параметры:

nanos - максимальное количество наносекунд ожидания

parkUntil

public static void parkUntil(long deadline)

Параметры:

deadline - абсолютное время, в миллисекундах с начала эпохи, до ожидания