org.camunda.bpm.engine.impl.util

Class SingleConsumerCondition

java.lang.Object

org.camunda.bpm.engine.impl.util.SingleConsumerCondition

public class SingleConsumerCondition
extends Object

MPSC Condition implementation.

Implementation Notes:

• await(long) may spuriously return before the deadline is reached.
• if signal() is called before the consumer thread calls await(long), the next call to await(long) returns immediately.

Constructor Summary

Constructors

Constructor and Description
SingleConsumerCondition(Thread consumer)

Method Summary

Methods

Modifier and Type	Method and Description
void	await(long millis)
void	signal()

Methods inherited from class java.lang.Object

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

Constructor Detail

SingleConsumerCondition

public SingleConsumerCondition(Thread consumer)

Method Detail

signal

public void signal()

await

public void await(long millis)