Package org.apache.logging.log4j.core.async

Class JCToolsBlockingQueueFactory<E>

java.lang.Object

org.apache.logging.log4j.core.async.JCToolsBlockingQueueFactory<E>

All Implemented Interfaces:

BlockingQueueFactory<E>

@Plugin(name="JCToolsBlockingQueue",
        category="Core",
        elementType="BlockingQueueFactory")
public class JCToolsBlockingQueueFactory<E>
extends java.lang.Object
implements BlockingQueueFactory<E>

Factory for creating instances of BlockingQueues backed by JCTools MpscArrayQueue.

Since:

2.7

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static interface	JCToolsBlockingQueueFactory.Idle
private static class	JCToolsBlockingQueueFactory.MpscBlockingQueue<E>	BlockingQueue wrapper for JCTools multiple producer single consumer array queue.
static class	JCToolsBlockingQueueFactory.WaitStrategy

Field Summary

Fields

Modifier and Type	Field	Description
private JCToolsBlockingQueueFactory.WaitStrategy	waitStrategy

Fields inherited from interface org.apache.logging.log4j.core.async.BlockingQueueFactory

ELEMENT_TYPE

Constructor Summary

Constructors

Modifier	Constructor	Description
private	JCToolsBlockingQueueFactory(JCToolsBlockingQueueFactory.WaitStrategy waitStrategy)

Method Summary

Modifier and Type	Method	Description
java.util.concurrent.BlockingQueue<E>	create(int capacity)	Creates a new BlockingQueue with the specified maximum capacity.
static <E> JCToolsBlockingQueueFactory<E>	createFactory(JCToolsBlockingQueueFactory.WaitStrategy waitStrategy)

Methods inherited from class java.lang.Object

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

Field Detail

waitStrategy

private final JCToolsBlockingQueueFactory.WaitStrategy waitStrategy

Constructor Detail

JCToolsBlockingQueueFactory

private JCToolsBlockingQueueFactory(JCToolsBlockingQueueFactory.WaitStrategy waitStrategy)

Method Detail

create

public java.util.concurrent.BlockingQueue<E> create(int capacity)

Description copied from interface: BlockingQueueFactory

Creates a new BlockingQueue with the specified maximum capacity. Note that not all implementations of BlockingQueue support a bounded capacity in which case the value is ignored.

Specified by:

create in interface BlockingQueueFactory<E>

Parameters:

capacity - maximum size of the queue if supported

Returns:

a new BlockingQueue

createFactory

@PluginFactory
public static <E> JCToolsBlockingQueueFactory<E> createFactory(@PluginAttribute(value="WaitStrategy",defaultString="PARK")
                                                               JCToolsBlockingQueueFactory.WaitStrategy waitStrategy)