compact1, compact2, compact3

java.util.concurrent

Класс CyclicBarrier

java.lang. Объект

java.util.concurrent. CyclicBarrier

public class CyclicBarrier
extends Object

Средство синхронизации, которое позволяет ряд потоков всем, ожидает друг друга, чтобы достигнуть общей точки барьера. CyclicBarriers полезны в программах, включающих фиксированную размерную сторону потоков, которые должны иногда ожидать друг друга. Барьер вызывают циклический, потому что он может быть снова использован после того, как потоки ожидания выпускаются.

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

Демонстрационное использование: Вот пример использования барьера в параллельном проекте разложения:

 
 class Solver {
   final int N;
   final float[][] data;
   final CyclicBarrier barrier;

   class Worker implements Runnable {
     int myRow;
     Worker(int row) { myRow = row; }
     public void run() {
       while (!done()) {
         processRow(myRow);

         try {
           barrier.await();
         } catch (InterruptedException ex) {
           return;
         } catch (BrokenBarrierException ex) {
           return;
         }
       }
     }
   }

   public Solver(float[][] matrix) {
     data = matrix;
     N = matrix.length;
     barrier = new CyclicBarrier(N,
                                 new Runnable() {
                                   public void run() {
                                     mergeRows(...);
                                   }
                                 });
     for (int i = 0; i < N; ++i)
       new Thread(new Worker(i)).start();

     waitUntilDone();
   }
 }

Здесь, каждый рабочий поток обрабатывает строку матрицы, тогда ожидает в барьере, пока все строки не были обработаны. Когда все строки обрабатываются предоставленный Runnable действие барьера выполняется и объединяет строки. Если слияние решит, что решение было найдено тогда, то done() возвратит true, и каждый рабочий завершит.

Если действие барьера не полагается на стороны, приостанавливаемые, когда оно выполняется, то любой из потоков в стороне мог выполнить то действие, когда оно выпускается. Облегчить это, каждый вызов await() возвращается прибытие индексируют того потока в барьере. Можно тогда выбрать, какой поток должен выполнить действие барьера, например:

 
 if (barrier.await() == 0) {
   // log the completion of this iteration
 }

CyclicBarrier использует категорическую модель поломки для отказавших попыток синхронизации: Если поток листы, на которые барьер указывает преждевременно из-за прерывания, отказа, или тайм-аута, все другие потоки, ожидающие в той точке барьера, также уедет неправильно через BrokenBarrierException (или InterruptedException если они также были прерваны в приблизительно то же самое время).

Эффекты непротиворечивости памяти: Действия в потоке до вызова await() произойдите - перед действиями, которые являются частью действия барьера, которые поочередно происходят - перед действиями после успешного возврата из соответствия await() в других потоках.

С тех пор:

1.5

См. Также:

CountDownLatch

Сводка конструктора

Конструкторы

Конструктор и Описание
CyclicBarrier(int parties) Создает новый CyclicBarrier, который сместится, когда данное число сторон (потоки) будет ожидать на него, и не выполняет предопределенное действие, когда барьер смещается.
CyclicBarrier(int parties, Runnable barrierAction) Создает новый CyclicBarrier, который сместится, когда данное число сторон (потоки) будет ожидать на него, и который выполнит данное действие барьера, когда барьер будет смещен, выполняется последним потоком, вводящим барьер.

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

Модификатор и Тип	Метод и Описание
int	await() Ожидает, пока все стороны не вызвали await на этот барьер.
int	await(long timeout, TimeUnit unit) Ожидает, пока все стороны не вызвали await на этот барьер, или указанное время ожидания протекает.
int	getNumberWaiting() Возвращает число сторон, в настоящий момент ожидая в барьере.
int	getParties() Возвращает число сторон, требуемых смещаться этот барьер.
boolean	isBroken() Запросы, если этот барьер находится в нарушенном состоянии.
void	reset() Сбрасывает барьер для его начального состояния.

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

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

Деталь конструктора

CyclicBarrier

public CyclicBarrier(int parties,
                     Runnable barrierAction)

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

Параметры:

parties - число потоков, которые должны вызвать await() прежде, чем барьер смещается

barrierAction - команда, чтобы выполниться, когда барьер смещается, или null если нет никакого действия

Броски:

IllegalArgumentException - если parties меньше чем 1

CyclicBarrier

public CyclicBarrier(int parties)

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

Параметры:

parties - число потоков, которые должны вызвать await() прежде, чем барьер смещается

Броски:

IllegalArgumentException - если parties меньше чем 1

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

getParties

public int getParties()

Возвращает число сторон, требуемых смещаться этот барьер.

Возвраты:

число сторон, требуемых смещаться этот барьер

ждать

public int await()
          throws InterruptedException,
                 BrokenBarrierException

Ожидает, пока все стороны не вызвали await на этот барьер.

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

• Последний поток прибывает; или
• Некоторый другой поток прерывает текущий поток; или
• Некоторый другой поток прерывает один из других потоков ожидания; или
• Некоторые другие времена потока, ожидая барьера; или
• Некоторый другой поток вызывает reset() на этом барьере.

Если текущий поток:

• установили его прерванное состояние на записи в этот метод; или
• прерывается, ожидая

тогда InterruptedException бросается и прерванное состояние текущего потока очищается.

Если барьер reset() в то время как любой поток ожидает, или если барьер повреждается, когда await вызывается, или в то время как любой поток ожидает, тогда BrokenBarrierException бросается.

Если какой-либо поток будет прерван, ожидая, то все другие потоки ожидания бросят BrokenBarrierException и барьер помещается в нарушенное состояние.

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

Возвраты:

прибытие индексирует текущего потока, где индексируют getParties() - 1 указывает, что первое, чтобы прибыть и обнулить указывает на последнее, чтобы прибыть

Броски:

InterruptedException - если текущий поток был прерван, ожидая

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

ждать

public int await(long timeout,
                 TimeUnit unit)
          throws InterruptedException,
                 BrokenBarrierException,
                 TimeoutException

Ожидает, пока все стороны не вызвали await на этот барьер, или указанное время ожидания протекает.

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

• Последний поток прибывает; или
• Указанный тайм-аут протекает; или
• Некоторый другой поток прерывает текущий поток; или
• Некоторый другой поток прерывает один из других потоков ожидания; или
• Некоторые другие времена потока, ожидая барьера; или
• Некоторый другой поток вызывает reset() на этом барьере.

Если текущий поток:

• установили его прерванное состояние на записи в этот метод; или
• прерывается, ожидая

тогда InterruptedException бросается и прерванное состояние текущего потока очищается.

Если указанное время ожидания протекает тогда TimeoutException бросается. Если время будет меньше чем или равно нулю, то метод не будет ожидать вообще.

Если барьер reset() в то время как любой поток ожидает, или если барьер повреждается, когда await вызывается, или в то время как любой поток ожидает, тогда BrokenBarrierException бросается.

Если какой-либо поток будет прерван, ожидая, то все другие потоки ожидания бросят BrokenBarrierException и барьер помещается в нарушенное состояние.

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

Параметры:

timeout - время, чтобы ожидать барьера

unit - единица измерения времени параметра тайм-аута

Возвраты:

прибытие индексирует текущего потока, где индексируют getParties() - 1 указывает, что первое, чтобы прибыть и обнулить указывает на последнее, чтобы прибыть

Броски:

InterruptedException - если текущий поток был прерван, ожидая

TimeoutException - если указанный тайм-аут протекает

BrokenBarrierException - если другой поток был прерван или синхронизирован, в то время как текущий поток ожидал, или барьер был сброшен, или барьер был поврежден когда await был вызван, или действие барьера, (если есть) отказавшее должный исключение

isBroken

public boolean isBroken()

Запросы, если этот барьер находится в нарушенном состоянии.

Возвраты:

true если одна или более сторон убегали из этого барьера из-за прерывания или тайм-аута начиная с конструкции или последнего сброса, или действия барьера, отказавшего из-за исключения; false иначе.

сброс

public void reset()

Сбрасывает барьер для его начального состояния. Если какие-либо стороны будут в настоящий момент ожидать в барьере, то они возвратятся с a BrokenBarrierException. Отметьте, что сбросы после поломки произошли по другим причинам, может быть усложнен, чтобы выполнить; потоки должны ресинхронизировать некоторым другим способом, и выбрать, чтобы выполнить сброс. Может быть предпочтительно вместо этого создать новый барьер для последующего использования.

getNumberWaiting

public int getNumberWaiting()

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

Возвраты:

число сторон, в настоящий момент блокированных в await()