warthreadengine.cpp

ftpserver very good sample

#include "StdAfx.h"
#include "WarThreadEngine.h"   // class implemented

#ifndef WAR_AUTO_LOCK_H
#   include "WarAutoLock.h"
#endif


#define AUTO_LOCK WarAutoLock my_lock(mLock)

/////////////////////////////// PUBLIC ///////////////////////////////////////

WarThreadEngine *WarThreadEngine::mspThis;

//============================= LIFECYCLE ====================================

WarThreadEngine::WarThreadEngine()
{
    if (NULL == mspThis)
        mspThis = this;
}// WarThreadEngine

WarThreadEngine::~WarThreadEngine()
{
    if (this == mspThis)
        mspThis = NULL;
}// ~WarThreadEngine


//============================= OPERATORS ====================================
//============================= OPERATIONS ===================================

void WarThreadEngine::SetPriOnAllThreads(const WarPrioritiesDefE newPriority)
{
    AUTO_LOCK;

    for(thread_set_t::iterator P = mThreads.begin()
        ; P != mThreads.end()
        ; ++P)
    {
        (*P)->SetPriority(newPriority);
    }
}

//============================= CALLBACK   ===================================
//============================= ACCESS     ===================================
//============================= INQUIRY    ===================================
/////////////////////////////// PROTECTED  ///////////////////////////////////

void WarThreadEngine::AddThread(WarThread *pThread)
{
    AUTO_LOCK;
    mThreads.insert(war_thread_ptr_t(pThread));
}

void WarThreadEngine::RemoveThread(WarThread *pThread)
{
    AUTO_LOCK;

    thread_set_t::iterator P = mThreads.find(war_thread_ptr_t(pThread));
    if (P != mThreads.end())
        mThreads.erase(P);
}

/////////////////////////////// PRIVATE    ///////////////////////////////////