Changeset 42b739d7 for tests/concurrent/channels/parallel_harness.hfa

Timestamp:

Jan 13, 2023, 12:49:52 PM (16 months ago)

Author:

caparsons <caparson@…>

Branches:

ADT, ast-experimental, master

Children:

b3d794fc, d61d034

Parents:

862658a

Message:

fixed termination synchronization in the channel benchmark to get rid of deadlock case

File:

• tests/concurrent/channels/parallel_harness.hfa (modified) (5 diffs)

tests/concurrent/channels/parallel_harness.hfa

@@ -38 +38 @@
 
 volatile bool cons_done = false, prod_done = false;
+volatile int cons_done_count = 0;
 size_t cons_check = 0, prod_check = 0;
 
@@ -64 +65 @@
     lock(o);
     total_operations += runs;
+    cons_done_count++;
     cons_check = cons_check ^ my_check;
     // sout | "C: " | runs;
@@ -128 +130 @@
     }
 
-    sleep(10`s);
+    sleep(1`s);
     prod_done = true;
 
@@ -137 +139 @@
     sout | "prods";
     cons_done = true;
-    for ( i; Channels ) {
-        // sout | get_count( channels[i] );
-        if ( get_count( channels[i] ) < Consumers ){
-            #ifdef BIG
-            bigObject b{0};
-            #endif
-            for ( j; Consumers ) {
+    while( cons_done_count != Consumers * Channels ) {
+        for ( i; Channels ) {
+            if ( has_waiting_consumers( channels[i] ) ){
                 #ifdef BIG
+                bigObject b{0};
                 insert( channels[i], b );
                 #else
@@ -151 +150 @@
             }
         }
-    }
+        
+    }
+    // for ( i; Channels ) {
+    //     // sout | get_count( channels[i] );
+    //     if ( get_count( channels[i] ) < Consumers ){
+    //         #ifdef BIG
+    //         bigObject b{0};
+    //         #endif
+    //         for ( j; Consumers ) {
+    //             #ifdef BIG
+    //             insert( channels[i], b );
+    //             #else
+    //             insert( channels[i], 0 );
+    //             #endif
+    //         }
+    //     }
+    // }
     sout | "cons";
     for ( i; Consumers * Channels ) {