Package kieker.monitoring.queue.putstrategy

Class SPBlockingPutStrategy

java.lang.Object

kieker.monitoring.queue.putstrategy.SPBlockingPutStrategy

All Implemented Interfaces:

PutStrategy

public class SPBlockingPutStrategy
extends Object
implements PutStrategy

This take strategy blocks if the queue is full.
IMPORTANT: This put strategy only works correctly if at most one producer accesses the queue.

Since:

1.13

Author:

Christian Wulf

Field Summary

Fields

Modifier and Type	Field	Description
int	storeFence

Constructor Summary

Constructors

Constructor	Description
SPBlockingPutStrategy()

Method Summary

Modifier and Type	Method	Description
<E> void	backoffOffer(Queue<E> q, E e)
void	signal()

Methods inherited from class java.lang.Object

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

Field Details

storeFence

public volatile int storeFence

Constructor Details

SPBlockingPutStrategy

public SPBlockingPutStrategy()

Method Details

signal

public void signal()

Specified by:

signal in interface PutStrategy

backoffOffer

public <E> void backoffOffer(Queue<E> q,
 E e)
                      throws InterruptedException

Specified by:

backoffOffer in interface PutStrategy

Type Parameters:

E - element type

Parameters:

q - queue

e - element

Throws:

InterruptedException - on interruption of the queue