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

File:

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

src/libcfa/concurrency/threads.c

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