737 |
|
}}); |
738 |
|
|
739 |
|
threadStarted.await(); |
740 |
< |
Callable<Boolean> oneConsumer = new Callable<>() { |
740 |
> |
Callable<Boolean> oneConsumer = new Callable<>() { |
741 |
|
public Boolean call() { |
742 |
|
return q.hasWaitingConsumer() |
743 |
|
&& q.getWaitingConsumerCount() == 1; }}; |
777 |
|
}}); |
778 |
|
|
779 |
|
threadStarted.await(); |
780 |
< |
Callable<Boolean> oneElement = new Callable<>() { |
780 |
> |
Callable<Boolean> oneElement = new Callable<>() { |
781 |
|
public Boolean call() { |
782 |
|
return !q.isEmpty() && q.size() == 1; }}; |
783 |
|
waitForThreadToEnterWaitState(t, oneElement); |