169 |
|
* |
170 |
|
* <p><b>Implementation notes</b>: This implementation restricts the |
171 |
|
* maximum number of parties to 65535. Attempts to register additional |
172 |
< |
* parties result in IllegalStateExceptions. However, you can and |
172 |
> |
* parties result in {@code IllegalStateException}. However, you can and |
173 |
|
* should create tiered phasers to accommodate arbitrarily large sets |
174 |
|
* of participants. |
175 |
|
* |
535 |
|
|
536 |
|
/** |
537 |
|
* Awaits the phase of the barrier to advance from the given phase |
538 |
< |
* value, or returns immediately if current phase of the barrier |
539 |
< |
* is not equal to the given phase value or this barrier is |
540 |
< |
* terminated. |
538 |
> |
* value, returning immediately if the current phase of the |
539 |
> |
* barrier is not equal to the given phase value or this barrier |
540 |
> |
* is terminated. |
541 |
|
* |
542 |
|
* @param phase the phase on entry to this method |
543 |
|
* @return the phase on exit from this method |
556 |
|
} |
557 |
|
|
558 |
|
/** |
559 |
< |
* Awaits the phase of the barrier to advance from the given |
560 |
< |
* value, or returns immediately if argument is negative or this |
561 |
< |
* barrier is terminated, or throws InterruptedException if |
562 |
< |
* interrupted while waiting. |
559 |
> |
* Awaits the phase of the barrier to advance from the given phase |
560 |
> |
* value, throwing {@code InterruptedException} if interrupted while |
561 |
> |
* waiting, or returning immediately if the current phase of the |
562 |
> |
* barrier is not equal to the given phase value or this barrier |
563 |
> |
* is terminated. |
564 |
|
* |
565 |
|
* @param phase the phase on entry to this method |
566 |
|
* @return the phase on exit from this method |
580 |
|
} |
581 |
|
|
582 |
|
/** |
583 |
< |
* Awaits the phase of the barrier to advance from the given value |
584 |
< |
* or the given timeout elapses, or returns immediately if |
585 |
< |
* argument is negative or this barrier is terminated. |
583 |
> |
* Awaits the phase of the barrier to advance from the given phase |
584 |
> |
* value or the given timeout to elapse, throwing |
585 |
> |
* {@code InterruptedException} if interrupted while waiting, or |
586 |
> |
* returning immediately if the current phase of the barrier is not |
587 |
> |
* equal to the given phase value or this barrier is terminated. |
588 |
|
* |
589 |
|
* @param phase the phase on entry to this method |
590 |
+ |
* @param timeout how long to wait before giving up, in units of |
591 |
+ |
* {@code unit} |
592 |
+ |
* @param unit a {@code TimeUnit} determining how to interpret the |
593 |
+ |
* {@code timeout} parameter |
594 |
|
* @return the phase on exit from this method |
595 |
|
* @throws InterruptedException if thread interrupted while waiting |
596 |
|
* @throws TimeoutException if timed out while waiting |
720 |
|
* only sensible to do so in designs where all parties register |
721 |
|
* before any arrive, and all {@link #awaitAdvance} at each phase. |
722 |
|
* Otherwise, you cannot ensure lack of interference from other |
723 |
< |
* parties during the the invocation of this method. |
723 |
> |
* parties during the invocation of this method. |
724 |
|
* |
725 |
|
* @param phase the phase number on entering the barrier |
726 |
|
* @param registeredParties the current number of registered parties |