Workspacelist() und Threads

[Manfred]

Hi,

wie muß man WorkSpaceList() benutzen um alle geöffneten DBF zu erhalten, egal in welchem Thread sie gerade geöffnet sind? Ich habe zwar etliches über Workspacelist hier gefunden, aber dazu nicht das, was ich meine verstanden zu haben.

[georg]

Hallo, Manfred -


so wie ich die Dokumentation zu verstehe, akzeptiert WorkSpaceList() einen Parameter, der auf zwei WorkSpaces zugreifen kann:

- DB_ZEROSPACE
- DB_WORKSPACE

Wobei der Zugriff mit DB_WORKSPACE sich auf den aktuellen WorkSpace, d.h. den aktuellen Thread bezieht. Thread-übergreifend ist das m.E. (leider) nicht möglich.

[Manfred]

Den aktuellen Space bekomme ich ja dann wohl ausgelesen. Ich möchte aber jetzt eine Infofunktion bauen, in der ich ALLE geöffneten DBF anzeigen lassen kann, egal wo sie geöffnet sind. Und das hatte ich mir eigentlich einfacher vorgestellt.

[Martin Altmann]

Moin,
ist doch einfach, wenn Du z.B. mit Klassen arbeitest
Ich weiß ja nun nicht, ob das in dem aktuellen Fall so ist - aber wenn, kannst Du doch in Deiner Klasse eine entsprechende Methode implementieren. Dann brauchst Du nur noch diese für alle Deine instantiierten Klassen abrufen und hast die Infos.

Viele Grüße,
Martin

[Manfred]

aha,

jetzt nochmal für Warmduscher.....

[georg]

Hallo,


die Kommunikation zwischen verschiedenen Threads ist sehr mühsam, wenn man solche Informationen braucht.

[ramses]

@Manfred, wenn du mit "egal wo geöffnet" auch verschiedene Programme meinst geht das nur noch wenn du ADS einsetzt und alle DBF's über die ADSDBE öffnest, da kann dir dann das Servermodul Auskunft geben.

Cu Carlo

[georg]

Hallo,


mal etwas ausführlicher:

derzeit erlaubt es Xbase++ von Hause aus nicht, von einem Thread auf einen anderen zuzugreifen, geschweige denn Informationen über einen anderen Thread zu ermitteln.

Ein Lösungsansatz wäre:

a) das Standard-Thread()-Objekt durch ein eigenes zu ersetzen, das eine Liste der aktiven Threads (genauer: Thread-Objekte) in einer CLASS VAR führt;
b) beim Beenden eines Threads muss die CLASS VAR entsprechend aktualisiert werden;

Wenn nun Informationen aus einem anderen Thread abgerufen werden müssen, geht man die CLASS VAR durch und schickt an alle (ausser dem Thread, in dem das passiert, da hat man ja den Zugriff) ein User-Event an das Thread-Objekt. In jedem Thread muss der Event-Loop dieses User-Event abgreifen und entsprechend reagieren, z.B. indem eine Liste der aktiven Dateien im Workspace zurückgeliefert wird.

Es spricht nichts dagegen, dass es verschiedene User-Events gibt, von der Abfrage über ein dbCloseAll() bis hin zum Terminieren des Threads.

Wohl gemerkt, dies setzt immer voraus, dass in jedem Thread ein Event-Loop vorhanden ist, der die User-Events abfängt und überprüft. Wenn ein Thread z.B. nur im Hintergrund drucken soll, ist der leider aussen vor.

Ein kleines Beispiel: Aus einem Browse können einzelne Sätze zur Bearbeitung ausgewählt werden (die Bearbeitung erfolgt in einem eigenen Thread), und wenn die Änderung abgeschlossen ist, soll der Browse aktualisiert werden. Dateizugriffe habe ich in einer Klassge gekapselt, daher nicht wundern:

Code: Alles auswählen

	oBro:notify        := {|oBrowser, oHistfile, aData| BrowserRefresh(oBrowser, oHistfile, aData)}

Im Event-Loop prüfe ich dann auf dieses Event:

Code: Alles auswählen

	WHILE nEvent <> xbeP_Close
		nEvent := AppEvent(@mp1, @mp2, @oXbp)
		DO CASE
		CASE nEvent = xbeP_User_notify
			Eval(oBro:notify, oBro, oAudioHist, mp1)

(xbeP_User_notify ist meines Wissens selbst definiert.)

Da der Bearbeitungsthread eine Referenz auf das Browse-Objekt übergibt, wird das notify-Event so ausgelöst:

Code: Alles auswählen

      PostAppEvent(xbeP_User_notify, {aSortOrder, aPattern}, 0, oBro)

PostAppEvent() schickt das Event an den Event des Threads, zu dem oBro gehört. Ohne oBro würde das notify-Event im eigenen Thread landen.

[Manfred]

wie sangen schon die fanta4?

Es könnte alles so einfach sein, ist es aber nicht.

Ok, dann lasse ich diese Idee erstmal in der Schubslade verschwinden.

[AUGE_OHR]

Es könnte alles so einfach sein, ist es aber nicht.

ist es doch ... wenn man ein entsprechendes Konzept hat
"nachträglich" wird es schwer mit

Code: Alles auswählen

   aInfo := ThreadInfo( THREADINFO_TID      + ;
                        THREADINFO_TOBJ       )

   iMax := LEN(aInfo)
   FOR i := 1 TO iMax
       oThread := aInfo[2]
       AADD(aResult,{aInfo[1], oThread:Get_My_Workspacelist() })
   NEXT

denn ein "normaler" Thread hat ja keine Method Get_My_Workspacelist()

angenommen du hast eine Class "Kunden" und du willst per MDI mehrere Instanzen als Thread laufen lassen dann solltest du eine "eigene" Thread Class verwenden und die Method Get_My_Workspacelist() hinzufügen.

Code: Alles auswählen

PROCEDURE KundThread(cAction,nSeekRec,oDraw,oKunden)
LOCAL aThread  := SP_Thread()
LOCAL nLen     := LEN(aThread)
LOCAL oKundThread
...
   // did we have any Thread
   IF nLen > 0
      // is there any "KUNDEN" in it
      IF ASCAN( aThread, {|x| x[ID_WHO] == "KUNDEN" } ) > 0
         // find MAX position
         AEVAL( aThread, {|x| IF(x[ID_WHO] == "KUNDEN",;
                              aPos[2] := MIN(x[ID_POS][2], aPos[2]),;
                              NIL ) } )
      ENDIF
   ELSE
      ...
   ENDIF

   IF VALTYPE(nSeekRec) = "N"
      nPosi   := ASCAN( aThread, {|x| x[ID_REC] == nSeekRec .AND.;
                                      x[ID_WHO] == "KUNDEN" } )
      IF nPosi > 0
         setappFocus( aThread[nPosi][ID_OBJ] )
         RETURN
      ENDIF
   ELSE
      ...
   ENDIF

   IF lBig
      bBlock  := {|| YKUNDEN(AppDesktop(),NIL,aPos,aSize,aPP,.T.,cAction ,nSeekRec,oDraw),;
                             AppDesktop(),NIL,aPos,aSize,aPP,.T.,cAction ,nSeekRec,oDraw  }
   ELSE
      bBlock  := {|| YKUNDEN(oDraw       ,NIL,aPos,aSize,aPP,.T.,cAction ,nSeekRec,oDraw),;
                             oDraw       ,NIL,aPos,aSize,aPP,.T.,cAction ,nSeekRec,oDraw  }
   ENDIF

   oKundThread := MyThread():new()
   oKundThread:start( bBlock )
   SP_ThreadAdd({nSeekRec,cAction,aPos,"","KUNDEN"})
RETURN

die SP_* (Pseudo-) Function gehören zum Thread der ein Array verwaltet.

Code: Alles auswählen

FUNCTION YKUNDEN(oParent, oOwner, aPos, aSize, aPP, lVisible, cAction, nSeekRec,oDraw)
   ...
   oKunden := KundClass():New( oParent, oOwner, aPos, aSize, aPP, lVisible )
   ...
   oKunden:create()
   ...
   SP_ThreadObj(nSeekRec,cAction,oKunden,"KUNDEN")
   ...
   nEvent := xbe_None
   DO WHILE .NOT. ( lExit .OR. oKunden:lThreadExit )
      nEvent := AppEvent ( @mp1, @mp2, @oXbp ,100*60*10)
      ...
      DO CASE
      ...
      OTHERWISE
         oXbp:HandleEvent ( nEvent, mp1, mp2 )
      ENDCASE
   ENDDO
   ...
   oKunden:Hide()
   oKunden:destroy()
   oKunden := NIL

   nPosi   := ASCAN( aThread, {|x| x[ID_REC] == nSeekRec .AND.;
                                   x[ID_WHO] == "KUNDEN" } )
   IF nPosi > 0
      SP_ThreadDel(nPosi)
   ENDIF
   SELECT(oldSel )
   ...

klar muss man das Array von den Threads dann noch "aufräumen" wenn man den Thread schliesst.