org.apache.flink.statefun.flink.core.queue

Class Locks

java.lang.Object

org.apache.flink.statefun.flink.core.queue.Locks

public final class Locks
extends java.lang.Object

Provides few implementations of Lock interface to be used with MpscQueue.

Method Summary

Modifier and Type	Method and Description
static Lock	jdkReentrantLock()
static Lock	spinLock()

Methods inherited from class java.lang.Object

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

Method Detail

spinLock

public static Lock spinLock()

jdkReentrantLock

public static Lock jdkReentrantLock()