Go4ThreadManager
Class TGo4ThreadHandler

class TGo4ThreadHandler

derived from TNamed

Thread Handler holds array of
Go4Thread Objects; each
Go4Thread handles one TThread and Mutex, Condition...
knows threadmanager instance
that owns the handler (that owns the
task connector which owns the thread handler,
respectively)
this threadmanager instance pointer is
given to each thread and runnable on
creation, thus each thread can
acces its manager methods by
threadmanager pointer

Author:

J. Adamczewski, Go4 project-DVEE-GSI Darmstadt, Germany, j.adamczewski@gsi.de

Version: 0.9

Since: jul 2000-oct 2001

Constructor Summary
	TGo4ThreadHandler(const TGo4ThreadHandler& right)
	TGo4ThreadHandler(const char * name, TGo4ThreadManager* parent)
private	TGo4ThreadHandler()

Destructor Summary
virtual synchronized	~TGo4ThreadHandler()

Method Summary
Bool_t	AddThread(TGo4Thread* gthr)           Adds Reference to (externally created) thread to Thread List
Bool_t	AllCreated()           Returns true if all root threads in list are existing, i.e. there is a pid and a valid thread pointer for them in go4 thread
Bool_t	AllRunning()           Returns true if all threads in list are running, i.e. all workfunctions were started
Bool_t	AllWaiting()           Returns true if all threads in list are waiting, i.e. all workfunctions are in condition wait
Bool_t	Cancel(const char * thname)           Cancels the ROOT Thread specified by the Go4 Thread of name 'name'.
Int_t	CancelAll()           Cancel all Threads in the thread list.
Bool_t	Create(const char * thname)           Launch the ROOT Thread specified by the Go4 Thread of name 'name'.
Int_t	CreateAll()           Launch all Threads in the thread list.
Int_t	DumpThreads(Int_t mode)           dumps thread process information to logging output i.e. file or anything
Int_t	GetEntries()           Number of threads in list
TGo4Thread*	GetThread(const char * name)           Access to Go4Thread by name.
const Bool_t	IsOperating()           Returns kTRUE if threadhandler performs any action that requires gSystem support.
Bool_t	NewThread(const char * name, TGo4Runnable* runnable)           Creates new internal Go4 Thread with name and adds it to the List External runnable is passed to specify the threaded actions
Bool_t	ReCreate(const char * thname)           ReCreate (Cancel and Create) all Threads in the thread list.
Int_t	ReCreateAll()           Recreate all Threads in the thread list.
Bool_t	RemoveThread(const char * name)           Remove thread by name from Thread List
Bool_t	Start(const char * thname)           Starts work function of the Go4 Thread of name 'name'.
Int_t	StartAll()           Start work function of all Threads in the thread list.
Bool_t	Stop(const char * thname)           Stops work function of the Go4 Thread of name 'name'.
Int_t	StopAll()           Start work function of all Threads in the thread list.

Methods inherited from class TNamed

operator=, Clear, Clone, Compare, Copy, FillBuffer, GetName, GetTitle, Hash, IsSortable, SetName, SetNameTitle, SetTitle, ls, Print, Sizeof, Class, Class_Name, Class_Version, Dictionary, IsA, ShowMembers, Streamer, StreamerNVirtual, DeclFileName, ImplFileLine, ImplFileName, DeclFileLine

Field Detail

fbIsOperating

private Bool_t fbIsOperating

kTRUE, if threadhandler performs any action that
requires gSystem support. Flag is checked by Manager
before Blocking the System using IsOperating() method

private TObjArray* fxArray

Array of Go4Threads

private TIterator* fxIterator

Iterator for Thread Array

private TMutex* fxListMutex

Mutex protecting thread array

protected TGo4ThreadManager* fxManager

Backlink to threadmanager who owns this thread handler.

supplierCardinality 1

clientCardinality 1

private TMutex* fxOperMutex

Mutex to protect IsOperating flag, flag is set kTRUE to
indicate that AppControl timer must not block, since
thread launching or canceling operation is performed by
thread handler. This state is checked by threadmanager in
BlockApp() method before enabling timer wait.
Mechanism should prevent timer deadlocks.

public TGo4ThreadHandler(const TGo4ThreadHandler& right)

public TGo4ThreadHandler(const char * name, TGo4ThreadManager* parent)

private TGo4ThreadHandler()

public virtual synchronized ~TGo4ThreadHandler()

public Bool_t AddThread(TGo4Thread* gthr)

Adds Reference to (externally created) thread
to Thread List

public Bool_t AllCreated()

Returns true if all root threads in list are existing,
i.e. there is a pid and a valid thread pointer for them
in go4 thread

public Bool_t AllRunning()

Returns true if all threads in list are running, i.e.
all workfunctions were started

public Bool_t AllWaiting()

Returns true if all threads in list are waiting, i.e.
all workfunctions are in condition wait

public Bool_t Cancel(const char * thname)

Cancels the ROOT Thread specified by the Go4 Thread of name 'name'.
Name of TThread and TGo4Thread is the same.

public Int_t CancelAll()

Cancel all Threads in the thread list.

public Bool_t Create(const char * thname)

Launch the ROOT Thread specified by the Go4 Thread of name 'name'.
Name of TThread and TGo4Thread is the same.

public Int_t CreateAll()

Launch all Threads in the thread list.

public Int_t DumpThreads(Int_t mode)

dumps thread process information to logging output
i.e. file or anything

public Int_t GetEntries()

Number of threads in list

public TGo4Thread* GetThread(const char * name)

Access to Go4Thread by name.

public const Bool_t IsOperating()

Returns kTRUE if threadhandler performs any action that
requires gSystem support. Flag is checked by Manager
before Blocking the System.

public Bool_t NewThread(const char * name, TGo4Runnable* runnable)

Creates new internal Go4 Thread with name and adds it to the List
External runnable is passed to specify the threaded actions

public Bool_t ReCreate(const char * thname)

ReCreate (Cancel and Create) all Threads in the thread list.

public Int_t ReCreateAll()

Recreate all Threads in the thread list.

public Bool_t RemoveThread(const char * name)

Remove thread by name
from Thread List

public Bool_t Start(const char * thname)

Starts work function of the Go4 Thread of name 'name'.
Workfunction will run in infinite loop until Stop().

public Int_t StartAll()

Start work function of all Threads in the thread list.

public Bool_t Stop(const char * thname)

Stops work function of the Go4 Thread of name 'name'.
Thread will suspend to condition wait without being killed.
Workfunction will continue loop on next Sart().

public Int_t StopAll()

Start work function of all Threads in the thread list.

Association Links

to Class TGo4ThreadManager

Backlink to threadmanager who owns this thread handler.

Client Cardinality 1

Supplier Cardinality 1

to Class TMutex

Mutex protecting thread array

to Class TIterator

Iterator for Thread Array

to Class TObjArray

Array of Go4Threads

to Class TMutex

Mutex to protect IsOperating flag, flag is set kTRUE to
indicate that AppControl timer must not block, since
thread launching or canceling operation is performed by
thread handler. This state is checked by threadmanager in
BlockApp() method before enabling timer wait.
Mechanism should prevent timer deadlocks.