org.jctools.queues.spec

Class ConcurrentQueueSpec

java.lang.Object

org.jctools.queues.spec.ConcurrentQueueSpec

public final class ConcurrentQueueSpec
extends Object

Author:

nitsanw

Field Summary

Fields

Modifier and Type	Field and Description
int	capacity
int	consumers
Ordering	ordering
Preference	preference
int	producers

Constructor Summary

Constructors

Constructor and Description
ConcurrentQueueSpec(int producers, int consumers, int capacity, Ordering ordering, Preference preference)

Method Summary

Modifier and Type	Method and Description
static ConcurrentQueueSpec	createBoundedMpmc(int capacity)
static ConcurrentQueueSpec	createBoundedMpsc(int capacity)
static ConcurrentQueueSpec	createBoundedSpmc(int capacity)
static ConcurrentQueueSpec	createBoundedSpsc(int capacity)
boolean	isBounded()
boolean	isMpmc()
boolean	isMpsc()
boolean	isSpmc()
boolean	isSpsc()

Methods inherited from class java.lang.Object

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

Field Detail

producers

public final int producers

consumers

public final int consumers

capacity

public final int capacity

ordering

public final Ordering ordering

preference

public final Preference preference

Constructor Detail

ConcurrentQueueSpec

public ConcurrentQueueSpec(int producers,
                           int consumers,
                           int capacity,
                           Ordering ordering,
                           Preference preference)

Method Detail

createBoundedSpsc

public static ConcurrentQueueSpec createBoundedSpsc(int capacity)

createBoundedMpsc

public static ConcurrentQueueSpec createBoundedMpsc(int capacity)

createBoundedSpmc

public static ConcurrentQueueSpec createBoundedSpmc(int capacity)

createBoundedMpmc

public static ConcurrentQueueSpec createBoundedMpmc(int capacity)

isSpsc

public boolean isSpsc()

isMpsc

public boolean isMpsc()

isSpmc

public boolean isSpmc()

isMpmc

public boolean isMpmc()

isBounded

public boolean isBounded()