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

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

trunk/SophyaLib/SysTools/zthread.h

@@ -31 +31 @@
   explicit      ZThread(size_t stacksize=0);
   virtual       ~ZThread();
+  //! Change the thread stack-size, specified in bytes. Can only be called before the thread is started
+  inline void   setStackSize(size_t ssz) { _ssize=ssz; }
+  //! Change the thread stack-size, specified in kilobytes. Can only be called before the thread is started
+  inline void   setStackSizekb(size_t sszk) { _ssize=sszk*1024; }
+
   void          start();
   void          cancel();
   void          kill(int sig);
+  void          join();
 
-  void          join();
   virtual void  run();
 
   //! Returns true if the thread has been created / started
-  bool IfStarted() { return ((_status > 0) ? true : false); }
+  bool IfStarted() { return (((_fgstarted)||(_status>0)) ? true : false); }
   //! Returns true if the thread is running 
-  bool IfRunning() { return ((_status == 1) ? true : false); }
+  bool IfRunning() { return ((_status == 2) ? true : false); }
   //! Returns true if the thread has ended normally 
-  bool IfEnded() { return ((_status == 2) ? true : false); }
+  bool IfEnded() { return ((_status == 3) ? true : false); }
   //! Returns true if the thread has been stopped (killed/canceled) 
-  bool IfStopped() { return ((_status == 3) ? true : false); }
+  bool IfStopped() { return ((_status == 5) ? true : false); }
 
   //! Sets the return code for the thread object
@@ -77 +82 @@
   // PTHREAD_CANCEL_DEFERRED  ou  PTHREAD_CANCEL_ASYNCHRONOUS
 
+  /*! 
+    \brief This method is only for internal use by zthread.cc and should not be called by users
+  */ 
   virtual void  run_p();
 
@@ -83 +91 @@
   size_t _ssize;
   int _rc;
-  int _status; // 0 : not started, 1: running, 2: ended, 3:stopped 
-
+  int _status; // 0 : not started, 1 : started, 2: running, 3: ended, 5:stopped 
+  bool _fgstarted;   // false -> true par appel a start()
   ZThreadAction _act;
   void * _usp;