Changeset 3855 in Sophya for trunk/SophyaLib/SysTools/parlex.cc

Timestamp:

Aug 12, 2010, 1:02:24 AM (15 years ago)

Author:

ansari

Message:

Ajout attribut nombre de threads ds ParallelTaskInterface, Reza 12/08/2010

File:

• trunk/SophyaLib/SysTools/parlex.cc (modified) (6 diffs)

trunk/SophyaLib/SysTools/parlex.cc

@@ -11 +11 @@
 
 /*!
+  \class ParallelTaskInterface
+  \ingroup SysTools
+  \brief Interface definition for parallel task object. 
+
+  The pure virtual method execute() should be redefined by the classes
+  inheriting from ParallelTaskInterface
+*/  
+ParallelTaskInterface::ParallelTaskInterface()
+{
+  setNbParallelThreads(0);
+}
+ParallelTaskInterface::~ParallelTaskInterface()
+{
+}
+/*!
+  \brief Define the number of parallel threads running to perform the task 
+
+  This method is called by ParallelExecutor object. If subclasses overwrite this method, 
+  base class method should be called to set the value of nbparallel_ attribute.
+*/
+void ParallelTaskInterface::setNbParallelThreads(int nbparthr)
+{
+  nbparallel_=nbparthr;
+}
+
+/*!
   \class ParallelTaskFunction 
   \ingroup SysTools
   \brief ParallelTaskInterface implementation for functions 
+
+  The function which are executed by the ParallelTaskFunction execute() method should
+  conform to the prototype:  int func(int tid, int nparthr)
+
+  tid (counting from zero) is the thread rank, and nparthr the number of parallel threads 
+  executing in the context
 */  
 //! Constructor with the specification of the function to be executed 
@@ -22 +54 @@
 int ParallelTaskFunction::execute(int tid)
 {
-  return parfunc_(tid);
+  return parfunc_(tid, getNbParallelThreads());
 }
 
@@ -184 +216 @@
     vrc_[i] = 0;
   }
+  ptask.setNbParallelThreads( nthr );
 }
 
@@ -195 +228 @@
 {
   if (vptask.size()<1) throw ParmError("ParallelExecutor(vector<ptask>/Error vptask.size()<1"); 
+  int nthr= (int)nThreads();
   for(size_t i=0; i<vpext_.size(); i++) {
     vpext_[i] = new ParalExThread( (*vptask[i]), i);
+    vptask[i]->setNbParallelThreads(nthr);
     vrc_[i] = 0;
   }
@@ -219 +254 @@
   for(size_t i=0; i<vpext_.size(); i++)
     vpext_[i]->setParallelTask(ptask);
+  ptask.setNbParallelThreads( (int)nThreads() );
   return;
 }
@@ -229 +265 @@
   if (vptask.size()!=vpext_.size()) 
     throw SzMismatchError("ParallelExecutor::SetParallelTask(vector<ptask>) - vptask.size()!=vpext.size()");
-  for(size_t i=0; i<vpext_.size(); i++)
+  int nthr= (int)nThreads();
+  for(size_t i=0; i<vpext_.size(); i++) {
     vpext_[i]->setParallelTask(*vptask[i]);
+    vptask[i]->setNbParallelThreads(nthr);
+  }
   return;
 }