org.compass.core.util.concurrent
Class ForceQueuePolicy

java.lang.Object
  extended by org.compass.core.util.concurrent.ForceQueuePolicy
All Implemented Interfaces:
RejectedExecutionHandler

public class ForceQueuePolicy
extends Object
implements RejectedExecutionHandler

A handler for rejected tasks that adds the specified element to this queue, waiting if necessary for space to become available.

Author:
kimchy

Constructor Summary
ForceQueuePolicy()
           
 
Method Summary
 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 Detail

ForceQueuePolicy

public ForceQueuePolicy()
Method Detail

rejectedExecution

public void rejectedExecution(Runnable r,
                              ThreadPoolExecutor executor)
Specified by:
rejectedExecution in interface RejectedExecutionHandler


Copyright (c) 2004-2008 The Compass Project.