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.
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
-
Field Details
-
storeFence
public volatile int storeFence
-
-
Constructor Details
-
SCBlockingTakeStrategy
public SCBlockingTakeStrategy()
-
-
Method Details
-
signal
public void signal()- Specified by:
signal
in interfaceTakeStrategy
-
waitPoll
public <E> E waitPoll(java.util.Queue<E> q) throws java.lang.InterruptedException- Specified by:
waitPoll
in interfaceTakeStrategy
- Throws:
java.lang.InterruptedException
-