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

File:

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

src/libcfa/concurrency/threads.c

@@ -27 +27 @@
 }
 
-extern processor * get_this_processor();
+/*thread_local*/ extern processor * this_processor;
 
 //-----------------------------------------------------------------------------
 // Forward declarations
-forall( dtype T | sized(T) | is_thread(T) )
+forall(otype T | is_thread(T) )
 void start( T* this );
 
-forall( dtype T | sized(T) | is_thread(T) )
+forall(otype 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;
@@ -51 +50 @@
 }
 
-forall( dtype T | sized(T) | is_thread(T) | { void ?{}(T*); } )
+forall(otype T | is_thread(T) )
 void ?{}( thread(T)* this ) {
         (&this->handle){};
@@ -57 +56 @@
 }
 
-forall( dtype T, ttype P | sized(T) | is_thread(T) | { void ?{}(T*, P); } )
+forall(otype T, ttype P | is_thread(T) | { void ?{}(T*, P); } )
 void ?{}( thread(T)* this, P params ) {
         (&this->handle){ params };
@@ -63 +62 @@
 }
 
-forall( dtype T | sized(T) | is_thread(T) | { void ^?{}(T*); } )
+forall(otype T | is_thread(T) )
 void ^?{}( thread(T)* this ) {
         stop(&this->handle);
@@ -78 +77 @@
 extern void thread_schedule( thread_h * );
 
-forall( dtype T | sized(T) | is_thread(T) )
+forall(otype 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();
-        get_this_processor()->current_coroutine = thrd_c;
+        this_processor->current_coroutine = thrd_c;
 
         // LIB_DEBUG_PRINTF("Thread start : %p (t %p, c %p)\n", handle, thrd_c, thrd_h);
@@ -94 +93 @@
 }
 
-forall( dtype T | sized(T) | is_thread(T) )
+forall(otype T | is_thread(T) )
 void stop( T* this ) {
         thread_h*  thrd = get_thread(this);