Changes in src/libcfa/concurrency/threads.c [8fcbb4c:ee897e4b]

File:

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

src/libcfa/concurrency/threads.c

@@ -17 +17 @@
 #include "threads"
 
-#include "kernel"
+#include "kernel_private.h"
 #include "libhdr.h"
 
@@ -44 +44 @@
         (&this->c){};
         this->c.name = "Anonymous Coroutine";
-        (&this->lock){};
+        (&this->terminated){};
         this->next = NULL;
 }
@@ -72 +72 @@
 //-----------------------------------------------------------------------------
 // Starting and stopping threads
-extern "C" {
-      forall(dtype T | is_thread(T))
-      void CtxInvokeThread(T * this);
-}
-
-extern void thread_schedule( thread * );
-
 forall( dtype T | is_thread(T) )
 void start( T* this ) {
@@ -92 +85 @@
         CtxSwitch( thrd_c->last->stack.context, thrd_c->stack.context );
 
-        fenv_t envp;
-        fegetenv( &envp );
-        LIB_DEBUG_PRINTF("Thread : mxcsr %x\n", envp.__mxcsr);
-        LIB_DEBUG_PRINTF("Thread started : %p (t %p, c %p)\n", this, thrd_c, thrd_h);
-
-        thread_schedule(thrd_h);
+        ScheduleThread(thrd_h);
 }
 
 forall( dtype T | is_thread(T) )
 void stop( T* this ) {
-        thread*  thrd = get_thread(this);
-        if( thrd->c.notHalted ) {
-                lock( &thrd->lock );
-        }
+        wait( & get_thread(this)->terminated ); 
 }
 
 void yield( void ) {
-        get_this_processor()->thread_action = Reschedule;
-        suspend();
+        ScheduleInternal( get_this_processor()->current_thread );
 }
 
 void ThreadCtxSwitch(coroutine* src, coroutine* dst) {
+        // set state of current coroutine to inactive
+        src->state = Inactive;
+        dst->state = Active;
+
+        //update the last resumer
         dst->last = src;
 
-        // set state of current coroutine to inactive
-        src->state = Inactive;
-
-        // set new coroutine that task is executing
+        // set new coroutine that the processor is executing
+        // and context switch to it
         get_this_processor()->current_coroutine = dst;  
-
-        // context switch to specified coroutine
         CtxSwitch( src->stack.context, dst->stack.context );
-        // when CtxSwitch returns we are back in the src coroutine
+        get_this_processor()->current_coroutine = src;  
 
         // set state of new coroutine to active
+        dst->state = Inactive;
         src->state = Active;
 }
@@ -134 +120 @@
 extern "C" {
         void __thread_signal_termination( thread * this ) {
-                this->c.state = Halt;
-                this->c.notHalted = false;
-                unlock( &this->lock );
+                this->c.state = Halted;
+                LIB_DEBUG_PRINTF("Thread end : %p\n", this);
+                signal( &this->terminated );    
         }
 }