Changeset 60819df7

Timestamp:

Jan 24, 2017, 11:45:35 AM (8 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, aaron-thesis, arm-eh, ast-experimental, cleanup-dtors, deferred_resn, demangler, enum, forall-pointer-decay, jacob/cs343-translation, jenkins-sandbox, master, new-ast, new-ast-unique-expr, new-env, no_list, persistent-indexer, pthread-emulation, qualifiedEnum, resolv-new, with_gc

Children:

2cdf6dc

Parents:

8def349

Message:

Update thread example to add processors

File:

• src/examples/thread.c (modified) (3 diffs)

src/examples/thread.c

@@ +1 @@
+#line 1 "thread.c"
 #include <fstream>
+#include <kernel>
 #include <stdlib>
 #include <threads>
@@ -10 +12 @@
 };
 
-// DECL_THREAD(MyThread)
+DECL_THREAD(MyThread)
+
+void ?{}( MyThread * this ) {
+}
 
 void ?{}( MyThread * this, unsigned id, unsigned count ) {
@@ -17 +22 @@
 }
 
-// void main(MyThread* this) {
-//      sout | "Thread" | this->id | " : Suspending" | this->count | "times" | endl;
-//      yield();
+void main(MyThread* this) {
+        sout | "Thread" | this->id | " : Suspending" | this->count | "times" | endl;
+        yield();
 
-//      for(int i = 0; i < this->count; i++) {
-//              sout | "Thread" | this->id | " : Suspend No." | i + 1 | endl;
-//              yield();
-//      }
-// }
+        for(int i = 0; i < this->count; i++) {
+                sout | "Thread" | this->id | " : Suspend No." | i + 1 | endl;
+                yield();
+        }
+}
 
 int main(int argc, char* argv[]) {
 
-        // unsigned itterations = 10u;
-        // if(argc == 2) { 
-        //      int val = ato(argv[1]);
-        //      assert(val >= 0);
-        //      itterations = val;
-        // }
+        unsigned itterations = 10u;
+        if(argc == 2) { 
+                int val = ato(argv[1]);
+                assert(val >= 0);
+                itterations = val;
+        }
 
         sout | "User main begin" | endl;
 
-        // {
-        //      thread(MyThread) thread1 = { 1u, itterations };
-        //      thread(MyThread) thread2 = { 2u, itterations };
-        // }
+        {
+                processor p;
+                {
+                        thread(MyThread) thread1 = { 1u, itterations };
+                        thread(MyThread) thread2 = { 2u, itterations };
+                }
+        }
 
         sout | "User main end" | endl;