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: //
|
---|