Package com.broadleafcommerce.datafeed.service.collector

Class BlockingRejectedExecutionHandler

java.lang.Object

com.broadleafcommerce.datafeed.service.collector.BlockingRejectedExecutionHandler

All Implemented Interfaces:

RejectedExecutionHandler

public class BlockingRejectedExecutionHandler
extends Object
implements RejectedExecutionHandler

This is a component to optionally configure a ThreadPoolTaskExecutor. The purpose of this is that, when the task queue is full, rather than rejecting another task, it delegates to the calling thread to queue the task or wait.

Care should be taken as this can cause thread starvation, but the trade-off is that when you have a task executor with a max queue size, it allows you to throttle so that you don't either run out of memory filling an unbounded queue, or get an exception because the queue was full.

Author:

Kelly Tisdell (ktisdell)

Constructor Summary

Constructors

Constructor	Description
BlockingRejectedExecutionHandler()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

BlockingRejectedExecutionHandler

public BlockingRejectedExecutionHandler()

Method Details

rejectedExecution

public void rejectedExecution(Runnable runnable,
 ThreadPoolExecutor executor)

Specified by:

rejectedExecution in interface RejectedExecutionHandler