988 |
|
} |
989 |
|
|
990 |
|
/** |
991 |
< |
* Decrements blockedCount and increments active count |
991 |
> |
* Decrements blockedCount and increments active count. |
992 |
|
*/ |
993 |
|
private void postBlock() { |
994 |
|
long c; |
1020 |
|
|
1021 |
|
/** |
1022 |
|
* Possibly blocks the given worker waiting for joinMe to |
1023 |
< |
* complete or timeout |
1023 |
> |
* complete or timeout. |
1024 |
|
* |
1025 |
|
* @param joinMe the task |
1026 |
|
* @param millis the wait time for underlying Object.wait |
1056 |
|
} |
1057 |
|
|
1058 |
|
/** |
1059 |
< |
* If necessary, compensates for blocker, and blocks |
1059 |
> |
* If necessary, compensates for blocker, and blocks. |
1060 |
|
*/ |
1061 |
|
private void awaitBlocker(ManagedBlocker blocker) |
1062 |
|
throws InterruptedException { |