Ryzom

		CAccessor(CUnfairSynchronized<T> *cs)

		{

			Synchronized = cs;

		}

		/// release the mutex

		~CAccessor()

		{

		}

		/// access to the Value

	/// queue of tasks, using list container instead of queue for DeleteTask methode

	CSynchronized<std::string>				_RunningTask;

	CSynchronized<std::deque<std::string> >	_DoneTaskQueue;

	/// thread pointer

bool CAsyncFileManager::cancelLoadTask(const CAsyncFileManager::ICancelCallback &callback)

{

	list<CWaitingTask> &rTaskQueue = acces.value ();

	list<CWaitingTask>::iterator it = rTaskQueue.begin();

	}

	// If not found, the current running task may be the one we want to cancel. Must wait it.

	// taskmanager will end just the current task async (if any) and won't start an other one.

	waitCurrentTaskToComplete ();

/*

bool CAsyncFileManager::cancelLoadMesh(const std::string& sMeshName)

{

	list<IRunnable*> &rTaskQueue = acces.value ();

	list<IRunnable*>::iterator it = rTaskQueue.begin();

void CAsyncFileManager::cancelSignal (bool *pSgn)

{

	list<CWaitingTask> &rTaskQueue = acces.value ();

	list<CWaitingTask>::iterator it = rTaskQueue.begin();

		nlSleep(10);

	// There should be no remaining Tasks

	nlassert(acces.value().empty());

	_Thread->wait();

	delete _Thread;

	while(_ThreadRunning)

	{

		{

			if(acces.value().empty())

			{

				runnableTask = NULL;

// Add a task to TaskManager

void CTaskManager::addTask(IRunnable *r, float priority)

{

	acces.value().push_back(CWaitingTask(r, priority));

}

/// Delete a task, only if task is not running, return true if found and deleted

bool CTaskManager::deleteTask(IRunnable *r)

{

	for(list<CWaitingTask>::iterator it = acces.value().begin(); it != acces.value().end(); it++)

	{

		if(it->Task == r)

/// Task list size

uint CTaskManager::taskListSize(void)

{

	return acces.value().size();

}

void CTaskManager::dump (std::vector<std::string> &result)

{

	CSynchronized<string>::CAccessor accesCurrent(&_RunningTask);

	CSynchronized<deque<string> >::CAccessor accesDone(&_DoneTaskQueue);

	const list<CWaitingTask> &taskList = acces.value();

uint CTaskManager::getNumWaitingTasks()

{

	return acces.value().size();

}

{

	if (_ChangePriorityCallback)

	{

		list<CWaitingTask> &taskList = acces.value();

		list<CWaitingTask>::iterator ite = taskList.begin();