source: src/tests/concurrent/examples/matrixSum.c @ 70969f8

ADTaaron-thesisarm-ehast-experimentalcleanup-dtorsdeferred_resndemanglerenumforall-pointer-decayjacob/cs343-translationjenkins-sandboxnew-astnew-ast-unique-exprnew-envno_listpersistent-indexerpthread-emulationqualifiedEnumresolv-newwith_gc
Last change on this file since 70969f8 was 971d9f2, checked in by Peter A. Buhr <pabuhr@…>, 7 years ago

add "with" clause to test programs

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