Changes in src/libcfa/concurrency/threads.c [bd98b58:8def349]

File:

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

src/libcfa/concurrency/threads.c

@@ -27 +27 @@
 }
 
-/*thread_local*/ extern processor * this_processor;
+extern processor * get_this_processor();
 
 //-----------------------------------------------------------------------------
 // Forward declarations
-forall(otype T | is_thread(T) )
+forall( dtype T | sized(T) | is_thread(T) )
 void start( T* this );
 
-forall(otype T | is_thread(T) )
+forall( dtype T | sized(T) | is_thread(T) )
 void stop( T* this );
 
@@ -42 +42 @@
 void ?{}(thread_h* this) {
         (&this->c){};
+        this->c.name = "Anonymous Coroutine";
         (&this->lock){};
         this->next = NULL;
@@ -50 +51 @@
 }
 
-forall(otype T | is_thread(T) )
+forall( dtype T | sized(T) | is_thread(T) | { void ?{}(T*); } )
 void ?{}( thread(T)* this ) {
         (&this->handle){};
@@ -56 +57 @@
 }
 
-forall(otype T, ttype P | is_thread(T) | { void ?{}(T*, P); } )
+forall( dtype T, ttype P | sized(T) | is_thread(T) | { void ?{}(T*, P); } )
 void ?{}( thread(T)* this, P params ) {
         (&this->handle){ params };
@@ -62 +63 @@
 }
 
-forall(otype T | is_thread(T) )
+forall( dtype T | sized(T) | is_thread(T) | { void ^?{}(T*); } )
 void ^?{}( thread(T)* this ) {
         stop(&this->handle);
@@ -77 +78 @@
 extern void thread_schedule( thread_h * );
 
-forall(otype T | is_thread(T))
+forall( dtype T | sized(T) | is_thread(T) )
 void start( T* this ) {
         coroutine* thrd_c = get_coroutine(this);
         thread_h*  thrd_h = get_thread   (this);
         thrd_c->last = this_coroutine();
-        this_processor->current_coroutine = thrd_c;
+        get_this_processor()->current_coroutine = thrd_c;
 
         // LIB_DEBUG_PRINTF("Thread start : %p (t %p, c %p)\n", handle, thrd_c, thrd_h);
@@ -93 +94 @@
 }
 
-forall(otype T | is_thread(T) )
+forall( dtype T | sized(T) | is_thread(T) )
 void stop( T* this ) {
         thread_h*  thrd = get_thread(this);