Changeset 2491 in Sophya for trunk/SophyaPI/PIext/pistdimgapp.cc

Timestamp:

Jan 4, 2004, 8:02:44 PM (22 years ago)

Author:

ansari

Message:

Suite des modifs pour piapp multi-threads
1) Ajout Mutex de synchronisation ds ls classe NamedObjMgr
2) Suite controle de gestion d'appel aux methodes de PIStdImgApp depuis
la classe elle-meme, a travers le NamedObjMgr
3) Modification de la boucle d'evenements, avec un thread de reveil
periodique

Reza, 4 Janvier 2004

File:

• trunk/SophyaPI/PIext/pistdimgapp.cc (modified) (10 diffs)

trunk/SophyaPI/PIext/pistdimgapp.cc

@@ -383 +383 @@
 }  
 
+/*
 class RunAlarm : public Periodic {
 public:
@@ -393 +394 @@
   PIStdImgApp* _app;
 };
-
+*/
+
+class Reveil : public ZThread {
+public:
+  Reveil(PIStdImgApp* app) :
+    ZThread() 
+  { _app = app; _fgstop = false; }
+  virtual ~Reveil() { }
+  inline void Stop() { _fgstop = true; }
+  virtual void run() 
+  {
+    while (!_fgstop) {
+      usleep(1000);
+      _app->getMutex().broadcast();
+    }
+  }
+
+  PIStdImgApp* _app;
+  bool _fgstop;
+};
 /* --Methode-- */
 void PIStdImgApp::Run()
@@ -409 +429 @@
 // Creation et demarrage de l'objet de reveil periodique
 // de la boucle d'evts 
-RunAlarm * mru = new RunAlarm(this);
-//mru->Start();
+/* RunAlarm * mru = new RunAlarm(this);
+   mru->Start(); */
+Reveil* mrv = new Reveil(this);
+mrv->start(); 
 // Demarrage du thread de l'interpreteur
 CmdInterpreter()->start();
@@ -420 +442 @@
 
 
+thr_glsyn.lock(); //  <ZThread> 
+//DBG int klp = 0;
 while (mStop) {
-  thr_glsyn.lock(); //  <ZThread> 
   fg_glsynlock = true;
+  int nevtproc = 0;
   while (XtAppPending(*appctx) != 0) {
     XtAppNextEvent(*appctx, &evt);
     XtDispatchEvent(&evt);
+    nevtproc++;
+    if (nevtproc >= 50)  break;
   }
   fg_glsynlock = false;
-  thr_glsyn.unlock(); //  <ZThread> 
-  //  thr_glsyn.wait();
-  usleep(1000);
-}
-
-delete mru;
+  thr_glsyn.wait();  //  <ZThread> 
+  //  cout << "DBG-Run:: Out of wait " << ++klp << endl;  
+    //  usleep(1000);
+}
+
+thr_glsyn.unlock();  //  <ZThread> 
+mrv->Stop();
+delete mrv;
+// delete mru;
 return;
 }
@@ -599 +628 @@
 
 /* --Methode-- */
-int PIStdImgApp::DispImage(P2DArrayAdapter* nouv, string const & name, string const& sop, int oid)
+int PIStdImgApp::DispImage(P2DArrayAdapter* nouv, string const & name, string const& sop, 
+                           int oid, bool fglock)
 {
 PIImage* pii;
@@ -626 +656 @@
 
 // <ZThread> global PIApplication event loop synchronisation
-ZSync zs(thr_glsyn, 2);  
+if (fglock) ZSync zs(thr_glsyn, 2);  
 
 // Choix de la taille de fenetre
@@ -682 +712 @@
 /* --Methode-- */
 int PIStdImgApp::DispScDrawer(PIDrawer* scd, string const & name, string const& sop, 
-                              string title, int oid)
+                              string title, int oid, bool fglock)
 {
 if (scd == NULL)
@@ -696 +726 @@
 
 // <ZThread> global PIApplication event loop synchronisation
-ZSync zs(thr_glsyn, 2);  
+if (fglock) ZSync zs(thr_glsyn, 2);  
 
 // Trace en superpoistion
@@ -785 +815 @@
 /* --Methode-- */
 int PIStdImgApp::Disp3DDrawer(PIDrawer3D* dr3, string const & name, string const& sop, 
-                              string title, int oid)
+                              string title, int oid, bool fglock)
 {
 if (dr3 == NULL)
@@ -800 +830 @@
 
 // <ZThread> global PIApplication event loop synchronisation
-ZSync zs(thr_glsyn, 2);  
+if (fglock) ZSync zs(thr_glsyn, 2);  
 
 // Trace en superpoistion