Changes in libcfa/src/concurrency/cofor.cfa [e4c3819:ee9ad40]

File:

• libcfa/src/concurrency/cofor.cfa (modified) (4 diffs)

libcfa/src/concurrency/cofor.cfa

@@ -4 +4 @@
 // cofor ( uC++ COFOR )
 
-thread co_runner {
+thread cofor_runner {
         ssize_t low, high;
         __cofor_body_t loop_body;
 };
 
-static void ?{}( co_runner & this, ssize_t low, ssize_t high, __cofor_body_t loop_body ) {
+static void ?{}( cofor_runner & this, ssize_t low, ssize_t high, __cofor_body_t loop_body ) {
         this.low = low;
         this.high = high;
@@ -15 +15 @@
 }
 
-void main( co_runner & this ) with( this ) {
+void main( cofor_runner & this ) with( this ) {
         for ( ssize_t i = low; i < high; i++ )
                 loop_body(i);
 }
 
-void cofor( ssize_t low, ssize_t high, __cofor_body_t loop_body ) libcfa_public {
+void __Cofor__( ssize_t low, ssize_t high, __cofor_body_t loop_body ) libcfa_public {
         ssize_t range = high - low;
   if ( range <= 0 ) return;
@@ -29 +29 @@
         ssize_t i = 0;
         ssize_t stride_iter = low;
-        co_runner * runners[ threads ];
+        cofor_runner * runners[ threads ];
         for ( i; threads ) {
                 runners[i] = alloc();
@@ -45 +45 @@
 }
 
-//////////////////////////////////////////////////////////////////////////////////////////
-// parallel (COBEGIN/COEND)
 
-thread para_runner {
-        parallel_stmt_t body;
-        void * arg;
-};
-
-static void ?{}( para_runner & this, parallel_stmt_t body, void * arg ) { 
-        this.body = body;
-        this.arg = arg;
-}
-
-void main( para_runner & this ) with( this ) { body( arg ); }
-
-void parallel( parallel_stmt_t * stmts, void ** args, size_t num ) libcfa_public {
-        para_runner * runners[ num ];
-        for ( i; num )
-                (*(runners[i] = malloc())){ stmts[i], args[i] };
-        for ( i; num )
-                delete( runners[i] );
-}
-