- Timestamp:
- Jan 13, 2023, 4:30:28 PM (16 months ago)
- Branches:
- ADT, ast-experimental, master
- Children:
- 34a1d2e, 997185e
- Parents:
- 8bb86ce (diff), 42b739d7 (diff)
Note: this is a merge changeset, the changes displayed below correspond to the merge itself.
Use the(diff)
links above to see all the changes relative to each parent. - Location:
- tests/concurrent/channels
- Files:
-
- 2 edited
Legend:
- Unmodified
- Added
- Removed
-
tests/concurrent/channels/parallel_harness.hfa
r8bb86ce rd61d034 38 38 39 39 volatile bool cons_done = false, prod_done = false; 40 volatile int cons_done_count = 0; 40 41 size_t cons_check = 0, prod_check = 0; 41 42 … … 64 65 lock(o); 65 66 total_operations += runs; 67 cons_done_count++; 66 68 cons_check = cons_check ^ my_check; 67 69 // sout | "C: " | runs; … … 128 130 } 129 131 130 sleep(1 0`s);132 sleep(1`s); 131 133 prod_done = true; 132 134 … … 137 139 sout | "prods"; 138 140 cons_done = true; 139 for ( i; Channels ) { 140 // sout | get_count( channels[i] ); 141 if ( get_count( channels[i] ) < Consumers ){ 142 #ifdef BIG 143 bigObject b{0}; 144 #endif 145 for ( j; Consumers ) { 141 while( cons_done_count != Consumers * Channels ) { 142 for ( i; Channels ) { 143 if ( has_waiting_consumers( channels[i] ) ){ 146 144 #ifdef BIG 145 bigObject b{0}; 147 146 insert( channels[i], b ); 148 147 #else … … 151 150 } 152 151 } 153 } 152 153 } 154 // for ( i; Channels ) { 155 // // sout | get_count( channels[i] ); 156 // if ( get_count( channels[i] ) < Consumers ){ 157 // #ifdef BIG 158 // bigObject b{0}; 159 // #endif 160 // for ( j; Consumers ) { 161 // #ifdef BIG 162 // insert( channels[i], b ); 163 // #else 164 // insert( channels[i], 0 ); 165 // #endif 166 // } 167 // } 168 // } 154 169 sout | "cons"; 155 170 for ( i; Consumers * Channels ) { -
tests/concurrent/channels/zero_size.cfa
r8bb86ce rd61d034 1 1 #include "parallel_harness.hfa" 2 2 3 size_t Processors = 10, Channels = 1 0, Producers = 40, Consumers = 40, ChannelSize = 0;3 size_t Processors = 10, Channels = 1, Producers = 10, Consumers = 10, ChannelSize = 0; 4 4 5 5 int main() {
Note: See TracChangeset
for help on using the changeset viewer.