Changes in src/libcfa/concurrency/thread.c [9c31349:17af7d1]

File:

• src/libcfa/concurrency/thread.c (modified) (5 diffs)

src/libcfa/concurrency/thread.c

@@ -35 +35 @@
 void start( T* this );
 
+forall( dtype T | is_thread(T) )
+void stop( T* this );
+
 //-----------------------------------------------------------------------------
 // Thread ctors and dtors
@@ -41 +44 @@
         (&this->cor){};
         this->cor.name = "Anonymous Coroutine";
-        this->mon.owner = this;
-        this->mon.recursion = 1;
+        (&this->terminated){};
         this->next = NULL;
 }
@@ -64 +66 @@
 forall( dtype T | sized(T) | is_thread(T) )
 void ^?{}( scoped(T)* this ) {
+        stop(&this->handle);
         ^(&this->handle){};
 }
@@ -83 +86 @@
 
         ScheduleThread(thrd_h);
+}
+
+forall( dtype T | is_thread(T) )
+void stop( T* this ) {
+        wait( & get_thread(this)->terminated ); 
 }
 
@@ -108 +116 @@
 }
 
+// C Helper to signal the termination of a thread_desc
+// Used in invoke.c
+extern "C" {
+        void __thread_signal_termination( thread_desc * this ) {
+                this->cor.state = Halted;
+                LIB_DEBUG_PRINTF("Thread end : %p\n", this);
+                signal( &this->terminated );    
+        }
+}
+
 // Local Variables: //
 // mode: c //