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

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.h (modified) (3 diffs)

trunk/SophyaLib/SysTools/parlex.h

@@ -5 +5 @@
 
 // Classes pour execution de taches paralleles en utilisant les threads
-//    R. Ansari       UPS+LAL IN2P3/CNRS  2005
+//    R. Ansari       UPS+LAL IN2P3/CNRS  2009-2010
 
 #include "zthread.h"
@@ -17 +17 @@
 //  s'executer en parallele
 //--------------------------------------------------------------------
-/*!
-  \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
-*/  
 class ParallelTaskInterface {
 public:
-  explicit       ParallelTaskInterface()  { }
-  virtual        ~ParallelTaskInterface() { }
+  explicit       ParallelTaskInterface();
+  virtual        ~ParallelTaskInterface(); 
   /*! This method should perform the actual computation. The parameter tid 
     is used by the ParallelExecutor class to identify the thread calling the method
   */
   virtual int    execute(int tid) = 0; 
+  //! Define the number of parallel threads running to perform the task (set by ParallelExecutor object)
+  virtual void   setNbParallelThreads(int nbparthr);
+  //! Return the number of parallel threads running to perform the task
+  inline  int    getNbParallelThreads() { return nbparallel_; }
+protected:
+  int nbparallel_;   // total number of parallel threads which will perform the job
 };
 
 //---- Implementation de ParallelTaskInterface pour l'execution des fonctions 
-typedef int (* ParalExFunction) (int);
+//! Prototype for functions which executed by ParallelTaskFunction objects
+typedef int (* ParalExFunction) (int,int);
 //----
-class ParallelTaskFunction {
+  class ParallelTaskFunction : public ParallelTaskInterface {
 public:
   explicit       ParallelTaskFunction(ParalExFunction f);
@@ -116 +115 @@
   //! Return RC for the ParalleTask.execute() of thread i 
   inline  int     getRC(size_t i) { return vrc_[i]; }
-  //! Return the execption condition for the ParalleTask.execute() of thread i 
+  //! Return the exception condition for the ParalleTask.execute() of thread i 
   inline  bool    IfException(size_t i, string& msg)  { return vpext_[i]->IfException(msg); }