Package kieker.monitoring.queue.takestrategy

Class SCBlockingTakeStrategy

java.lang.Object

kieker.monitoring.queue.takestrategy.SCBlockingTakeStrategy

All Implemented Interfaces:

TakeStrategy

public final class SCBlockingTakeStrategy
extends 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	Description
int	storeFence

Constructor Summary

Constructors

Constructor	Description
SCBlockingTakeStrategy()

Method Summary

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

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

SCBlockingTakeStrategy

public SCBlockingTakeStrategy()

Method Details

signal

public void signal()

Specified by:

signal in interface TakeStrategy

waitPoll

public <E> E waitPoll(Queue<E> q)
               throws InterruptedException

Specified by:

waitPoll in interface TakeStrategy

Throws:

InterruptedException