| 1 | // | 
|---|
| 2 | // Cforall Version 1.0.0 Copyright (C) 2017 University of Waterloo | 
|---|
| 3 | // | 
|---|
| 4 | // The contents of this file are covered under the licence agreement in the | 
|---|
| 5 | // file "LICENCE" distributed with Cforall. | 
|---|
| 6 | // | 
|---|
| 7 | // matrixSum.cfa -- | 
|---|
| 8 | // | 
|---|
| 9 | // Author           : Peter A. Buhr | 
|---|
| 10 | // Created On       : Mon Oct  9 08:29:28 2017 | 
|---|
| 11 | // Last Modified By : Peter A. Buhr | 
|---|
| 12 | // Last Modified On : Wed Feb 20 08:37:53 2019 | 
|---|
| 13 | // Update Count     : 16 | 
|---|
| 14 | // | 
|---|
| 15 |  | 
|---|
| 16 | #include <fstream.hfa> | 
|---|
| 17 | #include <kernel.hfa> | 
|---|
| 18 | #include <thread.hfa> | 
|---|
| 19 |  | 
|---|
| 20 | thread Adder { | 
|---|
| 21 | int * row, cols, & subtotal;                                            // communication | 
|---|
| 22 | }; | 
|---|
| 23 |  | 
|---|
| 24 | void ?{}( Adder & adder, int row[], int cols, int & subtotal ) { | 
|---|
| 25 | adder.[ row, cols ] = [ row, cols ];                            // expression disallowed in multi-member access | 
|---|
| 26 | &adder.subtotal = &subtotal; | 
|---|
| 27 | } | 
|---|
| 28 |  | 
|---|
| 29 | void main( Adder & adder ) with( adder ) {                              // thread starts here | 
|---|
| 30 | subtotal = 0; | 
|---|
| 31 | for ( c; cols ) { | 
|---|
| 32 | subtotal += row[c]; | 
|---|
| 33 | } // for | 
|---|
| 34 | } | 
|---|
| 35 |  | 
|---|
| 36 | int main() { | 
|---|
| 37 | /* const */ int rows = 10, cols = 1000; | 
|---|
| 38 | int matrix[rows][cols], subtotals[rows], total = 0; | 
|---|
| 39 | processor p;                                                                            // add kernel thread | 
|---|
| 40 |  | 
|---|
| 41 | for ( r; rows ) { | 
|---|
| 42 | for ( c; cols ) { | 
|---|
| 43 | matrix[r][c] = 1; | 
|---|
| 44 | } // for | 
|---|
| 45 | } // for | 
|---|
| 46 | Adder * adders[rows]; | 
|---|
| 47 | for ( r; rows ) {                                                                       // start threads to sum rows | 
|---|
| 48 | adders[r] = &(*malloc()){ matrix[r], cols, subtotals[r] }; | 
|---|
| 49 | //              adders[r] = new( matrix[r], cols, &subtotals[r] ); | 
|---|
| 50 | } // for | 
|---|
| 51 | for ( r; rows ) {                                                                       // wait for threads to finish | 
|---|
| 52 | delete( adders[r] ); | 
|---|
| 53 | total += subtotals[r];                                                  // total subtotals | 
|---|
| 54 | } // for | 
|---|
| 55 | sout | total; | 
|---|
| 56 | } | 
|---|
| 57 |  | 
|---|
| 58 | // Local Variables: // | 
|---|
| 59 | // tab-width: 4 // | 
|---|
| 60 | // compile-command: "cfa matrixSum.cfa" // | 
|---|
| 61 | // End: // | 
|---|