Changeset 3718 in Sophya for trunk/SophyaLib/SysTools/zthread.cc

Timestamp:

Dec 28, 2009, 10:05:51 PM (16 years ago)

Author:

ansari

Message:

1/ Corrections et modifications mineures ds ZThread, et ajout des classes

ParallelTaskInterface, ParalExThread, ParallelExecutor pour l'execution

de fonctions en parallele dans des threads, Reza 28/12/2009

File:

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

trunk/SophyaLib/SysTools/zthread.cc

@@ -63 +63 @@
 {
   ZThread * thr = (ZThread *)xthr;
-  if(thr->_status == 1) thr->_status = 2;
+  if(thr->_status == 2) thr->_status = 3;
   return;
 }
@@ -76 +76 @@
 /* ------ Classe ZThread  -------  */
 /*!
-  Constructor, with optional specification of the thread stack size.
+  Constructor, with optional specification of the thread stack size in bytes.
+  if not specified or zero, defaut system stack size is used.
 */
 ZThread::ZThread(size_t stacksize)
 {
   _status = 0;
+  _fgstarted = false;
   _ssize = 0;
   _act = NULL;
@@ -93 +95 @@
 
 /*!
-  Method which starts the thread.
+  Method which starts the thread. 
+  The thread object is created by a call to pthread_create() in this method.
 */
 void ZThread::start()
 {
-  if ( IfStarted() ) throw ZThreadExc("ZThread::Start() - Already started thread !");
+  if ( _fgstarted ) throw ZThreadExc("ZThread::Start() - Already started thread !");
+  _fgstarted = true;
+  _status = 1;
   int rc;
   pthread_attr_t tha;
@@ -154 +159 @@
 {
   if (_act)  _act(_usp);
-  setRC(0);      
+  exit(0);      
   return;
 }
@@ -165 +170 @@
 void ZThread::run_p()
 {
-  _status = 1;
+  _status = 2;
   pthread_cleanup_push(zthr_cleanup, (void *)this);
   run();
-  _status = 2;
+  _status = 3;
   pthread_exit(&(_rc));
   pthread_cleanup_pop(0);
@@ -212 +217 @@
 
 /*!
-  Constructor: Creates a associated pair of POSIX \c pthread_mutex_t 
+  Constructor: Creates an associated pair of POSIX \c pthread_mutex_t 
   and \c pthread_cond_t objects
   \param : if fgd == true , the destructor call pthread_mutex_destroy/pthread_cond_destroy