Package com.j_spaces.kernel.threadpool.policy

Class TimedBlockingPolicy

java.lang.Object

com.j_spaces.kernel.threadpool.policy.TimedBlockingPolicy

All Implemented Interfaces:

RejectedExecutionHandler

public class TimedBlockingPolicy
extends Object
implements RejectedExecutionHandler

A handler for rejected tasks that inserts the specified element into this queue, waiting if necessary up to the specified wait time for space to become available.

Constructor Summary

Constructors

Constructor	Description
TimedBlockingPolicy(long waitTime)
TimedBlockingPolicy(long waitTime, String poolName, boolean warnOnRejection, int warnThreshold, org.slf4j.Logger warnLogger)

Method Summary

Modifier and Type	Method	Description
void	rejectedExecution(Runnable r, ThreadPoolExecutor executor)

Methods inherited from class java.lang.Object

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

Constructor Details

TimedBlockingPolicy

public TimedBlockingPolicy(long waitTime)

Parameters:

waitTime - wait time in milliseconds for space to become available.

TimedBlockingPolicy

public TimedBlockingPolicy(long waitTime,
 String poolName,
 boolean warnOnRejection,
 int warnThreshold,
 org.slf4j.Logger warnLogger)

Method Details

rejectedExecution

public void rejectedExecution(Runnable r,
 ThreadPoolExecutor executor)

Specified by:

rejectedExecution in interface RejectedExecutionHandler