public class CallerBlocksPolicy
extends java.lang.Object
implements java.util.concurrent.RejectedExecutionHandler
RejectedExecutionHandler
that blocks the caller until
the executor has room in its queue, or a timeout occurs (in which
case a RejectedExecutionException
is thrown.Constructor and Description |
---|
CallerBlocksPolicy(long maxWait) |
Modifier and Type | Method and Description |
---|---|
void |
rejectedExecution(java.lang.Runnable r,
java.util.concurrent.ThreadPoolExecutor executor) |