- File:
-
- 1 edited
-
tests/concurrent/actors/executor.cfa (modified) (5 diffs)
Legend:
- Unmodified
- Added
- Removed
-
tests/concurrent/actors/executor.cfa
r1950837 rccf1d99 15 15 }; 16 16 void ?{}( d_actor & this ) with(this) { 17 ((actor &)this){}; 17 18 id = ids++; 18 19 gstart = (&this + (id / Set * Set - id)); // remember group-start array-element … … 23 24 24 25 struct d_msg { inline message; } shared_msg; 26 void ?{}( d_msg & this ) { ((message &) this){ Nodelete }; } 25 27 26 28 Allocation receive( d_actor & this, d_msg & msg ) with( this ) { … … 28 30 if ( recs % Batch == 0 ) { 29 31 for ( i; Batch ) { 30 gstart[sends % Set] <<shared_msg;32 gstart[sends % Set] | shared_msg; 31 33 sends += 1; 32 34 } … … 83 85 } // switch 84 86 87 85 88 executor e{ Processors, Processors, Processors == 1 ? 1 : Processors * 512, true }; 86 89 … … 94 97 95 98 for ( i; Actors ) { 96 actors[i] <<shared_msg;99 actors[i] | shared_msg; 97 100 } // for 98 101
Note:
See TracChangeset
for help on using the changeset viewer.