---

PsMultiThreadedController Class Reference

a controller that uses a multi-threaded scheduler More...

#include <PsMultiThreadedController.h>

Inheritance diagram for PsMultiThreadedController:

[legend]Collaboration diagram for PsMultiThreadedController:

[legend]List of all members.

Public Methods
	PsMultiThreadedController (PsObjectDescriptor &initialObjects, const PsDate &initialDate, unsigned int numberOfThreads)
	constructor
	PsMultiThreadedController (PsObjectDescriptor &initialObjects, const PsDate &initialDate)
	constructor
virtual	~PsMultiThreadedController ()
	destructor
virtual PsnScheduler *	createScheduler ()
	redefine to create a multihtreaded scheduler
virtual void	run ()
	redefine run to install a local memory manager
Protected Attributes
unsigned int	_numberOfThreads
	the number of threads created

---

Detailed Description

a controller that uses a multi-threaded scheduler

Author:

David Margery ( last change by )

Version:

Definition at line 33 of file PsMultiThreadedController.h.

---

Constructor & Destructor Documentation

PsMultiThreadedController::PsMultiThreadedController (  PsObjectDescriptor &    initialObjects, const PsDate &    initialDate, unsigned int    numberOfThreads )

constructor Parameters: numberOfThreads  the number of threads to create Definition at line 29 of file PsMultiThreadedController.cxx. References PsNameServer::getCanonicalRepresentation(), PsName::getNameServer(), PsDate, and PsName::setNameServer(). : PsController(initialObjects, initialDate), _numberOfThreads (numberOfThreads) { //convert the actual name Server to non ref counting name server to avoid contention on the name server locks during ref counting operations PsNoRefCountingNameServer<STL_ALLOC> * nameServer = new PsNoRefCountingNameServer<STL_ALLOC> (PsName::getNameServer()->getCanonicalRepresentation () ) ; PsName::setNameServer (nameServer ) ; }

PsMultiThreadedController::PsMultiThreadedController (  PsObjectDescriptor &    initialObjects, const PsDate &    initialDate )

constructor Parameters: numberOfThreads  the number of threads to create reads the number of threads from the NumberOfThreads scheduling parameter or defaults to 2 Definition at line 41 of file PsMultiThreadedController.cxx. References _numberOfThreads, PsConfigurationParameterDescriptor::getAssociatedString(), PsNameServer::getCanonicalRepresentation(), PsName::getNameServer(), PsSimulatedObject::getObjectDescriptor(), PsObjectDescriptor::getSchedulingParameters(), PsMultipleConfigurationParameter::getSubDescriptorByName(), PsDate, and PsName::setNameServer(). : PsController(initialObjects, initialDate), _numberOfThreads (2) { //convert the actual name Server to non ref counting name server to avoid contention on the name server locks during ref counting operations PsNoRefCountingNameServer<STL_ALLOC> * nameServer = new PsNoRefCountingNameServer<STL_ALLOC> (PsName::getNameServer()->getCanonicalRepresentation () ) ; PsName::setNameServer (nameServer ) ; if (getObjectDescriptor().getSchedulingParameters() != NULL ) { const PsConfigurationParameterDescriptor * param = getObjectDescriptor().getSchedulingParameters()->getSubDescriptorByName("NumberOfThreads") ; if (param != NULL ) { _numberOfThreads = atoi (param->getAssociatedString().c_str() ) ; } } }

PsMultiThreadedController::~PsMultiThreadedController (    )  [virtual]

destructor Definition at line 62 of file PsMultiThreadedController.cxx. { }

---

Member Function Documentation

PsnScheduler * PsMultiThreadedController::createScheduler (    )  [virtual]

redefine to create a multihtreaded scheduler Reimplemented from PsController. Definition at line 66 of file PsMultiThreadedController.cxx. References PsController::_nbStepsByCycle, and _numberOfThreads. { return new PsnMultiThreadedScheduler( _nbStepsByCycle , _numberOfThreads, true ) ; }

void PsMultiThreadedController::run (    )  [virtual]

redefine run to install a local memory manager Reimplemented from PsController. Definition at line 71 of file PsMultiThreadedController.cxx. References PsnMemoryManager::allocateSizeRemembered(), HeapStackTop::getSystemMemoryManager(), PsController::init(), PsnMemoryManager::init(), and PsController::run(). { PsnMemoryManager * currentMemoryManager = HeapStackTop::getSystemMemoryManager() ; assert ( currentMemoryManager != 0 ) ; size_t initialAllocatatedMemory = 1024 * 1024 ; void * startMemory = currentMemoryManager->allocateSizeRemembered ( initialAllocatatedMemory ) ; PsnDescriptorMemoryManager * descriptorMemoryManager = new PsnDescriptorMemoryManager ( *currentMemoryManager ) ; descriptorMemoryManager->init() ; PsnThreadMemoryManager * memoryManagerForThisThread ; memoryManagerForThisThread = new PsnThreadMemoryManager ( startMemory, initialAllocatatedMemory, *currentMemoryManager, *descriptorMemoryManager ) ; memoryManagerForThisThread -> init() ; HeapStackTop allocationContextForThisThread ( memoryManagerForThisThread ) ; PsController::run() ; }

---

Member Data Documentation

unsigned int PsMultiThreadedController::_numberOfThreads [protected]

the number of threads created Definition at line 57 of file PsMultiThreadedController.h. Referenced by createScheduler(), and PsMultiThreadedController().

---

The documentation for this class was generated from the following files:

• PsMultiThreadedController.h
• PsMultiThreadedController.cxx

---