Boost :: Нарушение доступа к потоку при вызове join

Question

У меня возникли проблемы при попытке создать многопоточный сервер. Все работает нормально, пока мне не нужно удалить клиента с сервера.

Сервер работает в своем собственном потоке, тогда у каждого клиента также есть свой собственный поток.

Я использую boost :: thread для всех потоков. Когда мне нужно остановить клиента, я звоню

void StopClient()
{
    assert(mThread);

    mStopMutex.lock();
    mStopRequested = true;
    mStopMutex.unlock();

    shutdown(mSocket,2);

    mThread->join();
}

Добавление точки останова на линию

shutdown(mSocket,2);

Я вижу, что mThread не существует! Означает ли это, что поток уже вышел? Вам всегда нужно вызывать join () для boost :: thread?

Если я разрешаю запускать код, я получаю сообщение об ошибке нарушения прав доступа.

Обновление

ServerThread

void StartServer() 
{
    assert(!mListenThread);
    mListenThread = boost::shared_ptr<boost::thread>(new boost::thread(boost::bind(&ServerThread::Listen, this)));
    mUpdateThread = boost::shared_ptr<boost::thread>(new boost::thread(boost::bind(&ServerThread::Update, this)));
}

void StopServer()
{
    assert(mListenThread);
    mStopRequested = true;

            mMutex.lock();
            for(int i = 0; i < mClients.size(); i++ )
                mClients[i]->StopClient();
            mMutex.unlock();

    mListenThread->join();
}

void Listen()
{
    while (!mStopRequested)
    {
        std::cout << "Waiting for connection" << std::endl;         
        if(mClientSocket = accept( mServerSocket, (sockaddr*) &mServerAddr, &addrlen ) )
        {
            mMutex.lock();
            if( mClients.size() > 0 )
            {
                for( int i = 0; i < mClients.size(); i++ )
                {
                    if( mClients[i]->getClientSocket() != mClientSocket )
                    {
                        ClientThread newClient;
                        newClient.Initialise(mClientSocket);
                        mClients.push_back(&newClient);
                        mClients[mClients.size()-1]->StartClient();
                        break;
                    }
                }
            }
            else
            {
                ClientThread newClient;
                newClient.Initialise(mClientSocket);
                mClients.push_back(&newClient);
                mClients[mClients.size()-1]->StartClient();
            }
            mMutex.unlock();
        }
    }
}          

void Update()
{
    while (!mStopRequested)
    {
        mMutex.lock();

        std::cout << "::::Server is updating!::::" << mClients.size() << std::endl;
        for( int i = 0; i< mClients.size(); i++ )
        {
            if( !mClients[i]->IsActive() )
            {
                mClients[i]->StopClient();
                mClients.erase( mClients.begin() + i );
            }
        }

        mMutex.unlock();

    }
}

ClientThread

void StartClient()
{
    assert(!mThread);
    mThread = boost::shared_ptr<boost::thread>(new boost::thread(boost::bind(&ClientThread::Update, this)));
}

void Update()
{
    bool stopRequested;
    do
    {
        mStopMutex.lock();
        stopRequested = mStopRequested;
        mStopMutex.unlock();

        std::cout << "lol" << std::endl;
        if( mTimeOut < 1000 )
        {
            mTimeOut++;
        }
        else
        {
            mActive = false;
        }

        boost::this_thread::interruption_point();
    }
    while( !stopRequested);
}

Answer 1

            ClientThread newClient;
            newClient.Initialise(mClientSocket);
            mClients.push_back(&newClient);

Это создает локальную переменную в стеке и помещает ее адрес в ваш список mClients.Затем область действия заканчивается, как и локальная переменная.Это оставляет ваш список mClients, указывающий на то, чего больше нет.

Answer 2

Здесь недостаточно кода, чтобы точно определить, что происходит, но вот что нужно проверить:

• Вероятно, у вас в клиентском потоке есть цикл обработки, проверяющий член mStopRequested. Перед выходом из цикла обработки происходит ли изменение элемента mThread?
• Является ли mThread пустым, когда вы получаете нарушение доступа? Или это какая-то другая ценность? Это допустимо перед установкой mStopRequested в true?