kieker.monitoring.queue.takestrategy

Class SCBlockingTakeStrategy

java.lang.Object

kieker.monitoring.queue.takestrategy.SCBlockingTakeStrategy

All Implemented Interfaces:

TakeStrategy

public final class SCBlockingTakeStrategy
extends java.lang.Object
implements TakeStrategy

This take strategy blocks if the queue is empty.
IMPORTANT: This take strategy only works correctly if at most one consumer accesses the queue.

Since:

1.13

Author:

Christian Wulf

Field Summary

Fields

Modifier and Type	Field and Description
int	storeFence

Constructor Summary

Constructors

Constructor and Description
SCBlockingTakeStrategy()

Method Summary

Modifier and Type	Method and Description
void	signal()
<E> E	waitPoll(java.util.Queue<E> q)

Methods inherited from class java.lang.Object

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

Field Detail

storeFence

public volatile int storeFence

Constructor Detail

SCBlockingTakeStrategy

public SCBlockingTakeStrategy()

Method Detail

signal

public void signal()

Specified by:

signal in interface TakeStrategy

waitPoll

public <E> E waitPoll(java.util.Queue<E> q)
               throws java.lang.InterruptedException

Specified by:

waitPoll in interface TakeStrategy

Throws:

java.lang.InterruptedException