Changes in libcfa/src/concurrency/thread.hfa [fd54fef:ab8c6a6]

File:

• libcfa/src/concurrency/thread.hfa (modified) (8 diffs)

libcfa/src/concurrency/thread.hfa

@@ -26 +26 @@
 //-----------------------------------------------------------------------------
 // thread trait
-trait is_thread(T &) {
+trait is_thread(dtype T) {
         void ^?{}(T& mutex this);
         void main(T& this);
@@ -32 +32 @@
 };
 
-FORALL_DATA_EXCEPTION(ThreadCancelled, (thread_t &), (thread_t)) (
+FORALL_DATA_EXCEPTION(ThreadCancelled, (dtype thread_t), (thread_t)) (
         thread_t * the_thread;
         exception_t * the_exception;
 );
 
-forall(T &)
+forall(dtype T)
 void copy(ThreadCancelled(T) * dst, ThreadCancelled(T) * src);
 
-forall(T &)
+forall(dtype T)
 const char * msg(ThreadCancelled(T) *);
 
@@ -47 +47 @@
 
 // Inline getters for threads/coroutines/monitors
-forall( T & | is_thread(T) )
+forall( dtype T | is_thread(T) )
 static inline $coroutine* get_coroutine(T & this) __attribute__((const)) { return &get_thread(this)->self_cor; }
 
-forall( T & | is_thread(T) )
+forall( dtype T | is_thread(T) )
 static inline $monitor  * get_monitor  (T & this) __attribute__((const)) { return &get_thread(this)->self_mon; }
 
@@ -60 +60 @@
 extern struct cluster * mainCluster;
 
-forall( T & | is_thread(T) )
+forall( dtype T | is_thread(T) )
 void __thrd_start( T & this, void (*)(T &) );
 
@@ -82 +82 @@
 };
 
-forall( T & | is_thread(T) | IS_EXCEPTION(ThreadCancelled, (T)) )
+forall( dtype T | is_thread(T) | IS_EXCEPTION(ThreadCancelled, (T)) )
 void ?{}( thread_dtor_guard_t & this, T & thrd, void(*)(ThreadCancelled(T) &) );
 void ^?{}( thread_dtor_guard_t & this );
@@ -89 +89 @@
 // thread runner
 // Structure that actually start and stop threads
-forall( T & | sized(T) | is_thread(T) )
+forall( dtype T | sized(T) | is_thread(T) )
 struct scoped {
         T handle;
 };
 
-forall( T & | sized(T) | is_thread(T) | { void ?{}(T&); } )
+forall( dtype T | sized(T) | is_thread(T) | { void ?{}(T&); } )
 void ?{}( scoped(T)& this );
 
-forall( T &, P... | sized(T) | is_thread(T) | { void ?{}(T&, P); } )
+forall( dtype T, ttype P | sized(T) | is_thread(T) | { void ?{}(T&, P); } )
 void ?{}( scoped(T)& this, P params );
 
-forall( T & | sized(T) | is_thread(T) )
+forall( dtype T | sized(T) | is_thread(T) )
 void ^?{}( scoped(T)& this );
 
@@ -115 +115 @@
 void unpark( $thread * this );
 
-forall( T & | is_thread(T) )
+forall( dtype T | is_thread(T) )
 static inline void unpark( T & this ) { if(!&this) return; unpark( get_thread( this ) );}
 
@@ -128 +128 @@
 //----------
 // join
-forall( T & | is_thread(T) | IS_RESUMPTION_EXCEPTION(ThreadCancelled, (T)) )
+forall( dtype T | is_thread(T) | IS_RESUMPTION_EXCEPTION(ThreadCancelled, (T)) )
 T & join( T & this );