blasd.apex.core.thread

Class OfferWithTimeoutPolicy

java.lang.Object

blasd.apex.core.thread.OfferWithTimeoutPolicy

All Implemented Interfaces:

RejectedExecutionHandler

Deprecated.

@Deprecated
public class OfferWithTimeoutPolicy
extends Object
implements RejectedExecutionHandler

A RejectedExecutionHandler which enables waiting for a given timeout before rejecting tasks if queue is full

Author:

Benoit Lacelle

Field Summary

Fields

Modifier and Type	Field and Description
protected AtomicBoolean	isGoingToLog Deprecated. This boolean makes sure we monitor the time to go through the queue not to often
protected static org.slf4j.Logger	LOGGER Deprecated.
protected int	timeout Deprecated.
protected TimeUnit	unit Deprecated.

Constructor Summary

Constructors

Constructor and Description
OfferWithTimeoutPolicy(int timeout, TimeUnit unit) Deprecated.

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

protected static final org.slf4j.Logger LOGGER

Deprecated.

timeout

protected int timeout

Deprecated.

unit

protected TimeUnit unit

Deprecated.

isGoingToLog

protected final AtomicBoolean isGoingToLog

Deprecated.

This boolean makes sure we monitor the time to go through the queue not to often

Constructor Detail

OfferWithTimeoutPolicy

public OfferWithTimeoutPolicy(int timeout,
                              TimeUnit unit)

Deprecated.

Method Detail

rejectedExecution

public void rejectedExecution(Runnable r,
                              ThreadPoolExecutor executor)

Deprecated.

Specified by:

rejectedExecution in interface RejectedExecutionHandler