co.codewizards.cloudstore.core.concurrent

Class CallerBlocksPolicy

java.lang.Object

co.codewizards.cloudstore.core.concurrent.CallerBlocksPolicy

All Implemented Interfaces:

RejectedExecutionHandler

public class CallerBlocksPolicy
extends Object
implements RejectedExecutionHandler

A handler for rejected tasks that blocks until the rejected task can be added to the queue.

The behaviour of an application using this policy is similar to one using the ThreadPoolExecutor.CallerRunsPolicy, but instead of running a certain Callable on the main thread, which may block this thread extremely long - much longer than the other Callables run, the main thread already continues as soon as any of the currently running tasks finished.

Author:

Marco หงุ่ยตระกูล-Schulze - marco at codewizards dot co

Constructor Summary

Constructors

Constructor and Description
CallerBlocksPolicy()

Method Summary

Methods

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

Methods inherited from class java.lang.Object

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

Constructor Detail

CallerBlocksPolicy

public CallerBlocksPolicy()

Method Detail

rejectedExecution

public void rejectedExecution(Runnable r,
                     ThreadPoolExecutor e)

Specified by:

rejectedExecution in interface RejectedExecutionHandler