Changeset 1033 in Sophya

Timestamp:

May 25, 2000, 11:42:08 AM (25 years ago)

Author:

ansari

Message:

programme test thread+PI+TArray , Reza 25/5/2000

Location:

trunk/SophyaProg/Tests

Files:

• JTCMakefile (modified) (1 diff)
• jtcpitarr.cc (added)
• jtctarr.cc (modified) (6 diffs)

trunk/SophyaProg/Tests/JTCMakefile

@@ -19 +19 @@
 
 LIBF =  $(SLB)libsophya.so 
-LIBS = -L$(SLB) -lPI -lextsophya -lsophya -L$(EXTSLBPATH) -lJTC  -lm 
+LIBS = -L$(SLB) -lPI -lextsophya -lsophya -L$(EXTSLBPATH) -lJTC -lXm -lXt -lX11 -lm 
 ifeq ($(MACHEROS),OSF1)
 LIBS := $(LIBS) -lfor

trunk/SophyaProg/Tests/jtctarr.cc

@@ -13 +13 @@
 
 // A global monitor for print synchronisation 
-JTCMonitor prtmon;
+JTCMonitor prtmon;  // <JThreadC++> 
 
 // A thread class for doing matrix computation 
-class MtxComputer : public JTCThread
+class MtxComputer : public JTCThread   // <JThreadC++> 
 {
 public:
@@ -38 +38 @@
   Matrix id;
   id = IdentityMatrix(1.,n);
+  double gmax = -1.e99;
+  double gmin = 1.e99;
+  int npb = 0;
   // Loop creating a random matrix, inverting it
   // and checking the result 
@@ -57 +60 @@
           if (fabs(x) > seuil)  nerr++;
         }
-      {  // Synchronized writing to cout stream
-        JTCSynchronized sync(prtmon);
+      if (min < gmin) gmin = min;
+      if (max > gmax) gmax = max;
+      if (nerr > 0) npb++;
+      {  // Synchronized writing to cout stream  
+        JTCSynchronized sync(prtmon);  // <JThreadC++> 
         cout << " ------- Thread[" << id_ << "] K= " 
              << k << "  NErr = " << nerr << endl;
         cout << "  Min(Diff) = " << min << " Max(Diff) = " << max << endl;
+        if (k == nloop_-1) {
+          double frac = (double)npb*100./(double)nloop_;
+          cout << " ...... Thread[" << id_ << "] End NPb= " << npb 
+               << " / NTot= " << nloop_ << " ( = " << frac << " %) " << endl;
+        cout << "  GMin(Diff) = " << gmin << " GMax(Diff) = " << gmax << endl;
+        cout << " ..................................................... " << endl;
+        }
       } 
     }
@@ -68 +81 @@
              << ") Msg= " << e.Msg() << endl;
     }
-    catch (JTCException const & e) {
+    catch (JTCException const & e) {  // <JThreadC++>
         cerr << " Catched JTCException in  Thread(" << (string)getName() 
              << ") Msg= " << e.getMessage() << endl;
@@ -86 +99 @@
          << " NThreads=1...4  NLoop=10...10^4  MtxSize=10...10^3 \n"
          << endl;
+    exit(0);
   }
 
@@ -100 +114 @@
   try {
     SophyaInit();  // Sophya Initialization
-    JTCInitialize iniJTC(narg, arg);
-    JTCThreadHandle t[MAXNTHR];
+    JTCInitialize iniJTC(narg, arg);  // <JThreadC++>  Initialize library
+
+    JTCThreadHandle t[MAXNTHR];  // <JThreadC++>  
     int k;
     for(k=0; k<nthr; k++)  t[k] = new MtxComputer(k, size, nloop);
     cout << " Starting threads ... " << endl;
-    for(k=0; k<nthr; k++) t[k]->start();
+    for(k=0; k<nthr; k++) t[k]->start();  // <JThreadC++> 
     // Waiting for threads to end
-    for(k=0; k<nthr; k++) t[k]->join();
+    for(k=0; k<nthr; k++) t[k]->join();   // <JThreadC++>
   }
   catch (PThrowable const & e) {
     cerr << " Catched PThrowable in main Msg= " << e.Msg() << endl;
   }
-  catch (JTCException const & e) {
+  catch (JTCException const & e) {  // <JThreadC++>
     cerr << " Catched JTCException in main Msg= " << e.getMessage() << endl;
   }