ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject [1/2] ignite git commit: IGNITE-2314: WIP.
Date Tue, 29 Dec 2015 10:07:21 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-2314 [created] 4f55c84f0


IGNITE-2314: WIP.


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/f8011bb5
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/f8011bb5
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/f8011bb5

Branch: refs/heads/ignite-2314
Commit: f8011bb5b1a34e8c3e7b1ccca022f19c6824f1cb
Parents: 4a1a80c
Author: vozerov-gridgain <vozerov@gridgain.com>
Authored: Tue Dec 29 12:51:26 2015 +0300
Committer: vozerov-gridgain <vozerov@gridgain.com>
Committed: Tue Dec 29 12:51:26 2015 +0300

----------------------------------------------------------------------
 .../util/ManyToOneConcurrentLinkedQueue.java    | 90 ++++++++++++++++++++
 1 file changed, 90 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/f8011bb5/modules/core/src/main/java/org/apache/ignite/internal/util/ManyToOneConcurrentLinkedQueue.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/ManyToOneConcurrentLinkedQueue.java
b/modules/core/src/main/java/org/apache/ignite/internal/util/ManyToOneConcurrentLinkedQueue.java
new file mode 100644
index 0000000..d30a5da
--- /dev/null
+++ b/modules/core/src/main/java/org/apache/ignite/internal/util/ManyToOneConcurrentLinkedQueue.java
@@ -0,0 +1,90 @@
+package org.apache.ignite.internal.util;
+
+import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;
+
+/**
+ *
+ */
+public class ManyToOneConcurrentLinkedQueue<E>
+{
+    protected static final AtomicReferenceFieldUpdater<ManyToOneConcurrentLinkedQueue,
Node> TAIL_UPD =
+        AtomicReferenceFieldUpdater.newUpdater(ManyToOneConcurrentLinkedQueue.class, Node.class,
"tail");
+
+    protected volatile ManyToOneConcurrentLinkedQueue.Node tail;
+
+    private Node head;
+
+    public ManyToOneConcurrentLinkedQueue()
+    {
+        head = new Node(null);
+        TAIL_UPD.lazySet(this, head);
+    }
+
+    public boolean offer(final E e)
+    {
+        if (null == e)
+        {
+            throw new NullPointerException("element cannot be null");
+        }
+
+        final Node newTail = new Node(e);
+        final Node prevTail = swapTail(newTail);
+        prevTail.setNextOrdered(newTail);
+
+        return true;
+    }
+
+    public E poll()
+    {
+        Object value = null;
+
+        final Node node = head.next;
+
+        if (null != node)
+        {
+            value = node.value;
+            node.value = null;
+            head = node;
+        }
+
+        return (E)value;
+    }
+
+    @SuppressWarnings("unchecked")
+    private Node swapTail(final Node newTail)
+    {
+        return TAIL_UPD.getAndSet(this, newTail);
+    }
+
+    /**
+     * Node with data.
+     */
+    private static class Node
+    {
+        public static final AtomicReferenceFieldUpdater<Node, Node> NODE_UPD =
+            AtomicReferenceFieldUpdater.newUpdater(Node.class, Node.class, "next");
+
+        Object value;
+        volatile Node next;
+
+        /**
+         * Constructor.
+         *
+         * @param value Value.
+         */
+        private Node(Object value)
+        {
+            this.value = value;
+        }
+
+        /**
+         * Set next node.
+         *
+         * @param next Next node.
+         */
+        void setNextOrdered(Node next)
+        {
+            NODE_UPD.lazySet(this, next);
+        }
+    }
+}
\ No newline at end of file


Mime
View raw message