# HG changeset patch # User cin # Date 1418171393 -3600 # Node ID 468d156e434efb847dcfffc6d7463ad6e3f7f499 # Parent 38d6a4db35d7743284d2b6a08bc1dd899c116036 working on linked list diff -r 38d6a4db35d7 -r 468d156e434e Implab/Implab.csproj --- a/Implab/Implab.csproj Wed Nov 19 13:34:09 2014 +0300 +++ b/Implab/Implab.csproj Wed Dec 10 01:29:53 2014 +0100 @@ -150,6 +150,8 @@ + + diff -r 38d6a4db35d7 -r 468d156e434e Implab/Parallels/MTLinkedList.cs --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/Implab/Parallels/MTLinkedList.cs Wed Dec 10 01:29:53 2014 +0100 @@ -0,0 +1,140 @@ +using System; +using System.Threading; + +namespace Implab.Parallels { + public class MTLinkedList where TNode : MTLinkedListNode { + TNode m_first; + TNode m_last; + + public void InsertAfter( TNode pos, TNode node) { + Safe.ArgumentNotNull(node, "node"); + if (!Attach(node)) + throw new InvalidOperationException("The specified node already attached to a list"); + + TNode next; + + while (true) { + // insert first if pos == null + next = pos == null ? m_first : pos.next; + node.prev = pos; + node.next = next; + if (next == m_first) { + if (next != Interlocked.CompareExchange(ref m_first, node, next)) + continue; + // race + } else { + if (next != Interlocked.CompareExchange(ref pos.next, node, next)) + continue; + // race + } + break; + } + + while (true) { + if (next == null) { + if (pos != Interlocked.CompareExchange(ref m_last, node, pos)) + continue; + } else { + if (pos != Interlocked.CompareExchange(ref next.prev, node, pos)) + continue; + } + break; + } + } + + public void InsertBefore( TNode pos, TNode node) { + Safe.ArgumentNotNull(node, "node"); + + if (!Attach(node)) + return; + + TNode prev; + + while (true) { + // insert first if pos == null + prev = pos == null ? m_last : pos.prev; + node.next = pos; + node.prev = prev; + if (prev == m_last) { + if (prev != Interlocked.CompareExchange(ref m_last, node, prev)) + continue; + // race + } else { + if (prev != Interlocked.CompareExchange(ref pos.prev, node, prev)) + continue; + // race + } + break; + } + + while (true) { + if (prev == null) { + if (pos != Interlocked.CompareExchange(ref m_first, node, pos)) + continue; + } else { + if (pos != Interlocked.CompareExchange(ref prev.next, node, pos)) + continue; + } + break; + } + } + + bool Detach(TNode node) { + MTLinkedList parent; + + do { + parent = node.parentList; + if (parent == null || parent != this) + return false; + } while(parent != Interlocked.CompareExchange(ref node.parentList, null, parent)); + } + + bool Attach(TNode node) { + MTLinkedList parent; + + do { + parent = node.parentList; + if (parent != null) + return false; + } while(parent != Interlocked.CompareExchange(ref node.parentList, this, parent)); + } + + public void Remove(TNode node) { + Safe.ArgumentNotNull(node, "node"); + + if (!Detach(node)) + return; + + TNode prev; + TNode next; + + while (true) { + prev = node.prev; + next = node.next; + + if (prev == null) { + if (node != Interlocked.CompareExchange(ref m_first, next, node)) + continue; + } else { + if (node != Interlocked.CompareExchange(ref prev.next, next, node)) + continue; + } + + break; + } + + while (true) { + if (next == null) { + if (node != Interlocked.CompareExchange(ref m_last, prev, node)) + continue; + } else { + if (node != Interlocked.CompareExchange(ref next.prev, prev, node)) + continue; + } + break; + } + } + + } +} + diff -r 38d6a4db35d7 -r 468d156e434e Implab/Parallels/MTLinkedListNode.cs --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/Implab/Parallels/MTLinkedListNode.cs Wed Dec 10 01:29:53 2014 +0100 @@ -0,0 +1,10 @@ +using System; + +namespace Implab.Parallels { + public class MTLinkedListNode where T : MTLinkedListNode { + public MTLinkedList parentList; + public TNode next; + public TNode prev; + } +} +