FQMessageQueue (org.codehaus.gpars)

| Detail:
Field
Constructor
Method

groovyx.gpars.util.FQMessageQueue

All Implemented Interfaces and Traits:

MessageQueue
```
@java.lang.SuppressWarnings({"rawtypes", "RawUseOfParameterizedType", "unchecked"})
public final class FQMessageQueue
extends java.lang.Object
```
An implementation of the message queue for actor and agent messaging using functional queues. It leverages the fact that in any moment there's only one reading thread accessing the queue and that potential read thread swap at the actor or agent thread pool synchronizes thread memory.
We also count on writers not to call the isEmpty() method

Authors:
Vaclav Pech

Nested Class Summary

Nested classes
Modifiers	Name	Description
`static class`	`FQMessageQueue.EmptyNode`
`static class`	`FQMessageQueue.Node`

Field Summary

Fields
Modifiers	Name	Description
`private FQMessageQueue.Node`	`inside`
`private FQMessageQueue.Node`	`outside`
`private java.util.concurrent.atomic.AtomicReferenceFieldUpdater`	`outsideUpdater`

Constructor Summary

Constructors
Constructor and description
`FQMessageQueue ()`

Methods Summary

Methods
Type	Name and description
`void`	`add(java.lang.Object element)`
`boolean`	`isEmpty()`
`java.lang.Object`	`poll()`
`private java.lang.Object`	`pollFromInside()`

Inherited Methods Summary

Inherited Methods
Methods inherited from class	Name
`class java.lang.Object`	`java.lang.Object#wait(), java.lang.Object#wait(long, int), java.lang.Object#wait(long), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll()`

- Field Detail
  - private FQMessageQueue.Node inside
  - @java.lang.SuppressWarnings({"FieldMayBeFinal"}) private FQMessageQueue.Node outside
  - private final java.util.concurrent.atomic.AtomicReferenceFieldUpdater outsideUpdater
- Constructor Detail
  - FQMessageQueue()
- Method Detail
  - @java.lang.Override public void add(java.lang.Object element)
  - @java.lang.Override public boolean isEmpty()
  - @java.lang.Override public java.lang.Object poll()
  - private java.lang.Object pollFromInside()

| Detail:
Field
Constructor
Method

Copyright © 2008–2014 Václav Pech. All Rights Reserved.