ChunkedPipelineConnection.Concurrent2LockQueue

java.lang.Object
- org.jredis.ri.alphazero.connection.ChunkedPipelineConnection.Concurrent2LockQueue<E>

All Implemented Interfaces:

java.lang.Iterable<E>, java.util.Collection<E>, java.util.concurrent.BlockingQueue<E>, java.util.Queue<E>

Enclosing class:

ChunkedPipelineConnection
```
static final class ChunkedPipelineConnection.Concurrent2LockQueue<E>
extends java.lang.Object
implements java.util.concurrent.BlockingQueue<E>
```
This was pretty much based on Maged M. Michael, and Michael L. Scott's 2 Lock concurrent queue as described in their paper, "Simple, Fast, and Practical Non-Blocking and Blocking Concurrent Algorithms" ({michael, scott}@cs.rochester.edu). For the specific use case of ChunkedPipelineConnection, we will have 1:1 producer-consumer concurrency and can do away with the 2 locks of their algorithm and get better performance. This class partially supports the BlockingQueue for the purposes of the pipeline. It is not intended for general use.

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

private static class ChunkedPipelineConnection.Concurrent2LockQueue.Node<E>

Nested Classes
Modifier and Type	Class and Description
`private static class`	`ChunkedPipelineConnection.Concurrent2LockQueue.Node<E>`

Field Summary

Fields
Modifier and Type Field and Description

private ChunkedPipelineConnection.Concurrent2LockQueue.Node<E> head

private ChunkedPipelineConnection.Concurrent2LockQueue.Node<E> tail

Fields
Modifier and Type	Field and Description
`private ChunkedPipelineConnection.Concurrent2LockQueue.Node<E>`	`head`
`private ChunkedPipelineConnection.Concurrent2LockQueue.Node<E>`	`tail`

Constructor Summary

Constructors
Constructor and Description

Concurrent2LockQueue()

Constructors
Constructor and Description
`Concurrent2LockQueue()`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`boolean`	`add(E e)`
`boolean`	`addAll(java.util.Collection<? extends E> c)`
`void`	`clear()`
`boolean`	`contains(java.lang.Object o)`
`boolean`	`containsAll(java.util.Collection<?> c)`
`int`	`drainTo(java.util.Collection<? super E> c)`
`int`	`drainTo(java.util.Collection<? super E> c, int maxElements)`
`E`	`element()`
`boolean`	`isEmpty()`
`java.util.Iterator<E>`	`iterator()`
`boolean`	`offer(E item)`
`boolean`	`offer(E e, long timeout, java.util.concurrent.TimeUnit unit)`
`E`	`peek()`
`E`	`poll()`
`E`	`poll(long timeout, java.util.concurrent.TimeUnit unit)`
`void`	`put(E e)`
`int`	`remainingCapacity()`
`E`	`remove()`
`boolean`	`remove(java.lang.Object o)`
`boolean`	`removeAll(java.util.Collection<?> c)`
`boolean`	`retainAll(java.util.Collection<?> c)`
`int`	`size()`
`E`	`take()`
`java.lang.Object[]`	`toArray()`
`<T> T[]`	`toArray(T[] a)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.Collection
equals, hashCode, parallelStream, removeIf, spliterator, stream

Methods inherited from interface java.lang.Iterable
forEach

- Field Detail
  - head
```
private transient volatile ChunkedPipelineConnection.Concurrent2LockQueue.Node<E> head
```
  - tail
```
private transient volatile ChunkedPipelineConnection.Concurrent2LockQueue.Node<E> tail
```
- Constructor Detail
  - Concurrent2LockQueue
```
public Concurrent2LockQueue()
```
- Method Detail
  - offer
```
public final boolean offer(E item)
```
    Specified by:
    
    offer in interface java.util.concurrent.BlockingQueue<E>
    
    Specified by:
    
    offer in interface java.util.Queue<E>
  - poll
```
public final E poll(long timeout,
                    java.util.concurrent.TimeUnit unit)
             throws java.lang.InterruptedException
```
    Specified by:
    
    poll in interface java.util.concurrent.BlockingQueue<E>
    
    Throws:
    
    java.lang.InterruptedException
  - poll
```
public final E poll()
```
    Specified by:
    
    poll in interface java.util.Queue<E>
  - peek
```
public final E peek()
```
    Specified by:
    
    peek in interface java.util.Queue<E>
  - take
```
public final E take()
             throws java.lang.InterruptedException
```
    Specified by:
    
    take in interface java.util.concurrent.BlockingQueue<E>
    
    Throws:
    
    java.lang.InterruptedException
  - remove
```
public final E remove()
```
    Specified by:
    
    remove in interface java.util.Queue<E>
  - add
```
public final boolean add(E e)
```
    Specified by:
    
    add in interface java.util.Collection<E>
    
    Specified by:
    
    add in interface java.util.concurrent.BlockingQueue<E>
    
    Specified by:
    
    add in interface java.util.Queue<E>
  - element
```
public final E element()
```
    Specified by:
    
    element in interface java.util.Queue<E>
  - addAll
```
public final boolean addAll(java.util.Collection<? extends E> c)
```
    Specified by:
    
    addAll in interface java.util.Collection<E>
  - clear
```
public final void clear()
```
    Specified by:
    
    clear in interface java.util.Collection<E>
  - contains
```
public final boolean contains(java.lang.Object o)
```
    Specified by:
    
    contains in interface java.util.Collection<E>
    
    Specified by:
    
    contains in interface java.util.concurrent.BlockingQueue<E>
  - containsAll
```
public final boolean containsAll(java.util.Collection<?> c)
```
    Specified by:
    
    containsAll in interface java.util.Collection<E>
  - isEmpty
```
public final boolean isEmpty()
```
    Specified by:
    
    isEmpty in interface java.util.Collection<E>
  - iterator
```
public final java.util.Iterator<E> iterator()
```
    Specified by:
    
    iterator in interface java.lang.Iterable<E>
    
    Specified by:
    
    iterator in interface java.util.Collection<E>
  - remove
```
public final boolean remove(java.lang.Object o)
```
    Specified by:
    
    remove in interface java.util.Collection<E>
    
    Specified by:
    
    remove in interface java.util.concurrent.BlockingQueue<E>
  - removeAll
```
public final boolean removeAll(java.util.Collection<?> c)
```
    Specified by:
    
    removeAll in interface java.util.Collection<E>
  - retainAll
```
public final boolean retainAll(java.util.Collection<?> c)
```
    Specified by:
    
    retainAll in interface java.util.Collection<E>
  - size
```
public final int size()
```
    Specified by:
    
    size in interface java.util.Collection<E>
  - toArray
```
public final java.lang.Object[] toArray()
```
    Specified by:
    
    toArray in interface java.util.Collection<E>
  - toArray
```
public final <T> T[] toArray(T[] a)
```
    Specified by:
    
    toArray in interface java.util.Collection<E>
  - drainTo
```
public final int drainTo(java.util.Collection<? super E> c)
```
    Specified by:
    
    drainTo in interface java.util.concurrent.BlockingQueue<E>
  - drainTo
```
public final int drainTo(java.util.Collection<? super E> c,
                         int maxElements)
```
    Specified by:
    
    drainTo in interface java.util.concurrent.BlockingQueue<E>
  - offer
```
public final boolean offer(E e,
                           long timeout,
                           java.util.concurrent.TimeUnit unit)
                    throws java.lang.InterruptedException
```
    Specified by:
    
    offer in interface java.util.concurrent.BlockingQueue<E>
    
    Throws:
    
    java.lang.InterruptedException
  - put
```
public final void put(E e)
               throws java.lang.InterruptedException
```
    Specified by:
    
    put in interface java.util.concurrent.BlockingQueue<E>
    
    Throws:
    
    java.lang.InterruptedException
  - remainingCapacity
```
public final int remainingCapacity()
```
    Specified by:
    
    remainingCapacity in interface java.util.concurrent.BlockingQueue<E>

Class ChunkedPipelineConnection.Concurrent2LockQueue<E>

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface java.util.Collection

Methods inherited from interface java.lang.Iterable

Field Detail

head

tail

Constructor Detail

Concurrent2LockQueue

Method Detail

offer

poll

poll

peek

take

remove

add

element

addAll

clear

contains

containsAll

isEmpty

iterator

remove

removeAll

retainAll

size

toArray

toArray

drainTo

drainTo

offer

put

remainingCapacity