Changes in / [18ea270:d63aeba]

Files:

• libcfa/src/concurrency/channel.hfa (modified) (1 diff)
• tests/concurrent/channels/parallel_harness.hfa (modified) (3 diffs)

libcfa/src/concurrency/channel.hfa

@@ -28 +28 @@
     exp_backoff_then_block_lock c_lock, p_lock;
     __spinlock_t mutex_lock;
-    char __padding[64]; // avoid false sharing in arrays
 };
 

tests/concurrent/channels/parallel_harness.hfa

@@ -100 +100 @@
 
 int test( size_t Processors, size_t Channels, size_t Producers, size_t Consumers, size_t ChannelSize ) {
-    size_t Clusters = Processors;
+    size_t Clusters = 1;
     // create a cluster
     cluster clus[Clusters];
@@ -108 +108 @@
     }
 
-    channels = aalloc( Channels );
+    channels = anew( Channels );
 
     // sout | "Processors: " | Processors | " ProdsPerChan: " | Producers | " ConsPerChan: " | Consumers | "Channels: " | Channels | " Channel Size: " | ChannelSize;
@@ -150 +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 ) {