compact1, compact2, compact3

java.util.concurrent.locks

Класс LockSupport

java.lang. Объект

java.util.concurrent.locks. LockSupport

public class LockSupport
extends Object

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

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

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

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

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

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

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

Демонстрационное Использование. Вот является эскиз первым прибыл - первым убыл неповторно используемой блокировки class:

 
 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());
   }
 }

Сводка метода

Модификатор и Тип	Метод и Описание
static Object	getBlocker(Thread t) Возвращает объект блокировщика, предоставленный новому вызову метода парка, который еще не разблокировал, или нуль если не блокированный.
static void	park() Отключает текущий поток в целях планирования потоков, если разрешение не доступно.
static void	park(Object blocker) Отключает текущий поток в целях планирования потоков, если разрешение не доступно.
static void	parkNanos(long nanos) Отключает текущий поток в целях планирования потоков, поскольку до указанного времени ожидания, если разрешение не доступно.
static void	parkNanos(Object blocker, long nanos) Отключает текущий поток в целях планирования потоков, поскольку до указанного времени ожидания, если разрешение не доступно.
static void	parkUntil(long deadline) Отключает текущий поток в целях планирования потоков, до указанного крайнего срока, если разрешение не доступно.
static void	parkUntil(Object blocker, long deadline) Отключает текущий поток в целях планирования потоков, до указанного крайнего срока, если разрешение не доступно.
static void	unpark(Thread thread) Делает доступным разрешение для данного потока, если это не было уже доступно.

Методы, наследованные от class java.lang. Объект

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Деталь метода

непарк

public static void unpark(Thread thread)

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

Параметры:

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

парк

public static void park(Object blocker)

Отключает текущий поток в целях планирования потоков, если разрешение не доступно.

Если разрешение доступно тогда, оно используется, и вызов сразу возвращается; иначе текущий поток становится отключенным в целях планирования потоков и бездействует, пока одна из трех вещей не происходит:

• Некоторый другой поток вызывает unpark с текущим потоком как цель; или
• Некоторый другой поток прерывает текущий поток; или
• Вызов побочно (то есть, ни по какой причине) возвраты.

Этот метод не сообщает, какой из них заставил метод возвращаться. Вызывающие стороны должны перепроверить условия, которые заставили поток парковать во-первых. Вызывающие стороны могут также определить, например, состояние прерывания потока по возврату.

Параметры:

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

С тех пор:

1.6

parkNanos

public static void parkNanos(Object blocker,
                             long nanos)

Отключает текущий поток в целях планирования потоков, поскольку до указанного времени ожидания, если разрешение не доступно.

Если разрешение доступно тогда, оно используется, и вызов сразу возвращается; иначе текущий поток становится отключенным в целях планирования потоков и бездействует, пока одна из четырех вещей не происходит:

• Некоторый другой поток вызывает unpark с текущим потоком как цель; или
• Некоторый другой поток прерывает текущий поток; или
• Указанное время ожидания протекает; или
• Вызов побочно (то есть, ни по какой причине) возвраты.

Этот метод не сообщает, какой из них заставил метод возвращаться. Вызывающие стороны должны перепроверить условия, которые заставили поток парковать во-первых. Вызывающие стороны могут также определить, например, состояние прерывания потока, или прошедшее время по возврату.

Параметры:

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

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

С тех пор:

1.6

parkUntil

public static void parkUntil(Object blocker,
                             long deadline)

Отключает текущий поток в целях планирования потоков, до указанного крайнего срока, если разрешение не доступно.

Если разрешение доступно тогда, оно используется, и вызов сразу возвращается; иначе текущий поток становится отключенным в целях планирования потоков и бездействует, пока одна из четырех вещей не происходит:

• Некоторый другой поток вызывает unpark с текущим потоком как цель; или
• Некоторый другой поток прерывает текущий поток; или
• Указанные передачи крайнего срока; или
• Вызов побочно (то есть, ни по какой причине) возвраты.

Этот метод не сообщает, какой из них заставил метод возвращаться. Вызывающие стороны должны перепроверить условия, которые заставили поток парковать во-первых. Вызывающие стороны могут также определить, например, состояние прерывания потока, или текущее время по возврату.

Параметры:

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

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

С тех пор:

1.6

getBlocker

public static Object getBlocker(Thread t)

Возвращает объект блокировщика, предоставленный новому вызову метода парка, который еще не разблокировал, или нуль если не блокированный. Возвращенное значение является только мгновенным снимком - поток, возможно, с тех пор разблокировал или блокировал на различном объекте блокировщика.

Параметры:

t - поток

Возвраты:

блокировщик

Броски:

NullPointerException - если параметром является нуль

С тех пор:

1.6

парк

public static void park()

Отключает текущий поток в целях планирования потоков, если разрешение не доступно.

Если разрешение доступно тогда, оно используется, и вызов сразу возвращается; иначе текущий поток становится отключенным в целях планирования потоков и бездействует, пока одна из трех вещей не происходит:

• Некоторый другой поток вызывает unpark с текущим потоком как цель; или
• Некоторый другой поток прерывает текущий поток; или
• Вызов побочно (то есть, ни по какой причине) возвраты.

Этот метод не сообщает, какой из них заставил метод возвращаться. Вызывающие стороны должны перепроверить условия, которые заставили поток парковать во-первых. Вызывающие стороны могут также определить, например, состояние прерывания потока по возврату.

parkNanos

public static void parkNanos(long nanos)

Отключает текущий поток в целях планирования потоков, поскольку до указанного времени ожидания, если разрешение не доступно.

Если разрешение доступно тогда, оно используется, и вызов сразу возвращается; иначе текущий поток становится отключенным в целях планирования потоков и бездействует, пока одна из четырех вещей не происходит:

• Некоторый другой поток вызывает unpark с текущим потоком как цель; или
• Некоторый другой поток прерывает текущий поток; или
• Указанное время ожидания протекает; или
• Вызов побочно (то есть, ни по какой причине) возвраты.

Этот метод не сообщает, какой из них заставил метод возвращаться. Вызывающие стороны должны перепроверить условия, которые заставили поток парковать во-первых. Вызывающие стороны могут также определить, например, состояние прерывания потока, или прошедшее время по возврату.

Параметры:

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

parkUntil

public static void parkUntil(long deadline)

Отключает текущий поток в целях планирования потоков, до указанного крайнего срока, если разрешение не доступно.

Если разрешение доступно тогда, оно используется, и вызов сразу возвращается; иначе текущий поток становится отключенным в целях планирования потоков и бездействует, пока одна из четырех вещей не происходит:

• Некоторый другой поток вызывает unpark с текущим потоком как цель; или
• Некоторый другой поток прерывает текущий поток; или
• Указанные передачи крайнего срока; или
• Вызов побочно (то есть, ни по какой причине) возвраты.

Этот метод не сообщает, какой из них заставил метод возвращаться. Вызывающие стороны должны перепроверить условия, которые заставили поток парковать во-первых. Вызывающие стороны могут также определить, например, состояние прерывания потока, или текущее время по возврату.

Параметры:

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