Changeset 3c6480b7 for libcfa/src/bits/multi_list.cfa

Timestamp:

Dec 4, 2020, 11:49:34 AM (3 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, arm-eh, ast-experimental, enum, forall-pointer-decay, jacob/cs343-translation, master, new-ast-unique-expr, pthread-emulation, qualifiedEnum

Children:

fe3d9ab

Parents:

36ec816 (diff), 54f89d5 (diff)
Note: this is a merge changeset, the changes displayed below correspond to the merge itself.
Use the (diff) links above to see all the changes relative to each parent.

Message:

Merge branch 'master' of plg.uwaterloo.ca:software/cfa/cfa-cc

File:

• libcfa/src/bits/multi_list.cfa (modified) (3 diffs)

libcfa/src/bits/multi_list.cfa

@@ -2 +2 @@
 #include <stdlib.hfa>
 #include "sequence.hfa"
+#include "queue.hfa"
 #include "stack.hfa"
 
@@ -8 +9 @@
 struct TaskDL {
         inline Seqable;
-        Task & task_;
+        Task & node;
 };
 void ?{}( TaskDL & this, Task & task ) with( this ) {
         ((Seqable &)this){};
-        &task_ = &task;                                                                         // pointer to containing node
+        &node = &task;                                                                          // pointer to containing node
 }
 Task & task( TaskDL & this ) with( this ) {                             // getter routine for containing node
-        return task_;
+        return node;
+}
+
+struct TaskSL {
+        inline Colable;
+        Task & node;
+};
+void ?{}( TaskSL & this, Task & task ) with( this ) {
+        ((Colable &)this){};
+        &node = &task;                                                                          // pointer to containing node
+}
+Task & task( TaskSL & this ) with( this ) {                             // getter routine for containing node
+        return node;
 }
 
@@ -21 +34 @@
         TaskDL clusterRef;                                                                      // list of tasks on cluster
         TaskDL readyRef;                                                                        // list of tasks on ready queue
-        // other stuff
+        TaskSL mutexRef;                                                                        // list of tasks on mutex queue
+        int id;
 };
-void ?{}( Task & this ) with( this ) {
+void ?{}( Task & this, int id ) with( this ) {
         ((TaskDL &)clusterRef){ this };
         ((TaskDL &)readyRef){ this };
+        ((TaskSL &)mutexRef){ this };
+        this.id = id;
 }
 
 int main() {
         Sequence(TaskDL) clustList, readyList;                          // task lists
+        Queue(TaskSL) mutexList;
         enum { Lnth = 10 };
 
-        for ( Lnth ) {
-                Task & task = *new();                                                   // create task node
+        for ( id; Lnth ) {
+                Task & task = *new( id );                                               // create task node
                 addHead( clustList, task.clusterRef );                  // insert on lists in opposite directions
                 addTail( readyList, task.readyRef );
+                addHead( mutexList, task.mutexRef );
         }
 
-        SeqIter(TaskDL) iter;
+        SeqIter(TaskDL) sqiter;
         TaskDL & dl;
+        TaskSL & sl;
 
         sout | nlOff;
-        for ( over( iter, clustList ); iter >> dl; ) {          // print lists
-                sout | &task( dl );
+        for ( over( sqiter, clustList ); sqiter >> dl; ) {      // print lists
+                Task & tmp = task( dl ); sout | tmp.id;
+                // sout | task( dl ).id;
         }
         sout | nl;
-        for ( SeqIter(TaskDL) iter = { readyList }; iter >> dl; ) {
-                sout | &task( dl );
+        for ( over( sqiter, readyList ); sqiter >> dl; ) {
+                Task & tmp = task( dl ); sout | tmp.id;
+                // sout | task( dl ).id;
         }
         sout | nl;
-        for ( Lnth ) {                                                                          // remove nodes from clustList
+        for ( QueueIter(TaskSL) qiter = { mutexList }; qiter >> sl; ) { // print lists
+                Task & tmp = task( sl ); sout | tmp.id;
+                // sout | task( sl ).id;
+        }
+        sout | nl;
+        for ( Lnth ) {                                                                          // remove nodes from clustList. mutexList
                 dropHead( clustList );
+                drop( mutexList );
         }
+        // Simultaneous deletion only safe if all nodes are traversed in same direction.
         for ( Lnth ) {                                                                          // remove nodes from readyList and safe to delete nodes
                 delete( &task( dropHead( readyList ) ) );
         }
 
-        // Stack(TaskDL) fredStack;
-        // for ( Lnth ) {
-        //      Task & task = *new();                                                   // create task node
-        //      push( fredStack, task.clusterRef );                             // insert on lists in opposite directions
-        // }
+        // Re-purpose Seqable as Colable
+        Stack(TaskDL) mutexStack;
+        for ( id; Lnth ) {
+                Task & task = *new( id );                                               // create task node
+                push( mutexStack, task.clusterRef );                    // insert on lists in opposite directions
+        }
+        for ( StackIter(TaskDL) stiter = { mutexStack }; stiter >> dl; ) {
+                Task & tmp = task( dl ); sout | tmp.id;
+                // sout | task( dl ).id;
+        }
+        sout | nl;
+        for ( Lnth ) {                                                                          // remove nodes from readyList and safe to delete nodes
+                delete( &task( pop( mutexStack ) ) );
+        }
 }